如何创建一个Kafka流，该流在每天的特定时间运行，从某个主题读取消息，进行一些转换以及将消息写回到另一个主题。
例如，每天晚上9点运行的流将获取推送到某个主题的所有消息，并将它们写入另一个主题。
我尝试开窗，但是所有示例仅与聚合有关。我不必做汇总。
我正在使用Java DSL
最佳答案
编写Java代码以执行所需的操作，并配置crontab以在需要时运行Java。
关于java - 创建在Java的特定时间每天运行的Kafka流，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/56688270/