用Java实现samza转换成flink

2024-12-13 分类：技术专栏 阅读(54) 评论(0)

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