用Java实现samza转换成flink

2024-12-13 分类：未分类 阅读(9) 评论(0)

假设我们有一个简单的Samza作业，它从Kafka读取数据，进行一些处理，然后将结果写回到Kafka。我们将这个逻辑迁移到Flink。