Flink 1.13.2Kafka 2.6.2思路与环境从kafka中读取数据 根据逻辑判断分配到不同的topic中去需要重写Flink Kafka的Key序列化器，并通过加入自己的逻辑主动往指定的topic发送消息。首先配置Kafka信息Properties props = new Properties();props.put("bootstrap.servers","10.116.0.16:9