java - 创建每天在java中的特定时间运行的Kafka流

Question

如何创建每天在特定时间运行的 Kafka 流，从某个主题读取消息，进行一些转换并将消息写回到不同的主题。

例如，每天晚上 9 点运行的流，会获取推送到某个主题的所有消息并将它们写入另一个主题。

我尝试了窗口化，但所有示例都仅与聚合有关。我不必进行聚合。 我正在使用 java DSL

Answer 1

编写您的 Java 代码来执行您想要的操作，并配置 crontab 以在您需要时运行您的 Java。