Re:回复：FlinkKafkaProducer没有写入多个topic的功能

Tue, 07 Jul 2020 20:18:50 -0700 

兄弟，感谢
















在 2020-07-08 11:04:40，"夏帅" <[email protected]> 写道：

你好,可以尝试自定义KafkaSerializationSchema来实现你的业务场景
class DemoSerializationSchema extends KafkaSerializationSchema[DemoBean] {
override def serialize(element: DemoBean, timestamp: lang.Long): 
ProducerRecord[Array[Byte], Array[Byte]] = {
new ProducerRecord[Array[Byte], Array[Byte]](element.getTopic, element.getValue)
  }
}
------------------------------------------------------------------
发件人：[email protected] <[email protected]>
发送时间：2020年7月8日(星期三) 10:59
收件人：user-zh <[email protected]>
主　题：FlinkKafkaProducer没有写入多个topic的功能


我有一个需求是通过读取一个kafka的主题的数据经过flink处理再写入到多个kafka的主题中（写入的主题是动态的，数据中能解析到需要写入到的目的地主题），
但是FlinkKafkaProducer好像只能写入一个主题里面？



[email protected]

回复