本文讨论了使用Kafka 3.x(KRaft)和Flink 1.20+进行流处理实验的复现步骤,包括环境设置、事件时间与处理时间窗口、Kafka日志解读、事务处理和检查点间隔等内容。实验结果将记录在output/目录中,以确保实验的准确性。
完成下面两步后,将自动完成登录并继续当前操作。