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