stream-processing 实验复现
原文中文，约700字，阅读约需2分钟。
📝
内容提要
本文讨论了使用Kafka 3.x（KRaft）和Flink 1.20+进行流处理实验的复现步骤，包括环境设置、事件时间与处理时间窗口、Kafka日志解读、事务处理和检查点间隔等内容。实验结果将记录在output/目录中，以确保实验的准确性。
🎯
关键要点
-
使用Kafka 3.x（KRaft）和Flink 1.20+进行流处理实验的复现步骤。
-
环境设置包括在WSL2中启动Docker和JVM。
-
通过docker compose up -d命令启动Kafka和Flink的JobManager/TaskManager。
-
提供多个脚本用于不同实验的执行和说明。
-
实验结果记录在output/目录中，以确保实验的准确性。
-
每轮基准测试至少执行3次以取中位数，禁止使用未运行的输出。
🏷️
