y[Byte]] = {
> new ProducerRecord[Array[Byte], Array[Byte]](element.getTopic,
> element.getValue)
> }
> }
> --
> 发件人：18579099...@163.com <18579099...@163.com>
> 发送时间：2020年7月8日(星期三) 10:59
> 收件人：user-zh
> 主 题：FlinkKafkaProducer没有写入多个topic的功能
>
>
> 我有一个需求是通过读取一个kafka的主题的数据经过flink处理再写入到多个kafka的主题中（写入的主题是动态的，数据中能解析到需要写入到的目的地主题），
> 但是FlinkKafkaProducer好像只能写入一个主题里面？
>
>
>
> 18579099...@163.com
>
>
]] = {
new ProducerRecord[Array[Byte], Array[Byte]](element.getTopic, element.getValue)
}
}
--
发件人：18579099...@163.com <18579099...@163.com>
发送时间：2020年7月8日(星期三) 10:59
收件人：user-zh
主 题：FlinkKafkaProducer没有写入多个topic的功能
我有一个需求是通过读取一个kafka的
,
element.getValue)
}
}
--
发件人：18579099...@163.com <18579099...@163.com>
发送时间：2020年7月8日(星期三) 10:59
收件人：user-zh
主 题：FlinkKafkaProducer没有写入多个topic的功能
我有一个需求是通过读取一个kafka的主题的数据经过flink处理再写入到多个kafka的主题中（写入的主题是动态的，数据中能解析到需要写入到的目的地主
我有一个需求是通过读取一个kafka的主题的数据经过flink处理再写入到多个kafka的主题中（写入的主题是动态的，数据中能解析到需要写入到的目的地主题），
但是FlinkKafkaProducer好像只能写入一个主题里面？
18579099...@163.com
