【发布时间】：2020-05-05 17:02:27
【问题描述】：
由于我是 kafka flink 连接器的新手，请帮助我建议一些简单的示例程序，其中 kafka 写入一个主题，flink 监听它并将值与 pom.xml 一起显示。
【问题讨论】：
【发布时间】：2020-05-05 17:02:27
【问题描述】：
Flink 操作操场正是这样做的。这是一个学习如何使用 Flink 的完整环境。 The documentation 描述了这个应用程序正在做什么，如何启动和停止它，如何使用 Flink Web UI、REST API 和 CLI 来控制和观察正在发生的事情等。
这个基于 docker 的示例包括：
- Kafka 代理和 Zookeeper
- a simple click event generator that writes events to a Kafka input topic
- a Flink application that counts these events with time windows and writes the results to Kafka output topic
- 用于运行 Flink 作业的小型 Flink 集群
pom.xml 文件是here。
【讨论】：
-
你能解释一下上面的程序是做什么的吗？
-
事件生成器每 15 秒将 6 个页面中的每个页面的 1000 个点击事件写入 Kafka 输入主题。 Flink 作业读取并计算这些事件并将结果写入 Kafka 输出主题。