与flink一起发送多主题kafka接收器

sqserrrh  于 2021-06-06  发布在  Kafka
关注(0)|答案(1)|浏览(365)

我有这样一个数据流:

DataStream[myTuple(topic, value)]

我想在相关主题中发送一个特定值。
所以我试着这样做:

new FlinkKafkaProducer010[myTuple](
  "default_topic",
  new KeyedSerializationSchema[myTuple](){
    override def getTargetTopic(element: myTuple): String = element.topic
    override def serializeKey(element: myTuple): Array[Byte] = null
    override def serializeValue(element: myTuple): Array[Byte] = new SimpleStringSchema().serialize(element.value)
  },
  properties)

但它不起作用,我有一个警告:

WARN  org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase  - Overwriting the 'key.serializer' is not recommended
WARN  org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducerBase  - Overwriting the 'value.serializer' is not recommended

我不知道怎么做,换个方法。谢谢你的帮助。

sirbozc5

sirbozc51#

你可能会 key.serializer 以及 value.serializer 在你的房子里。不应该这样做,因为这样会覆盖序列化程序( ByteArraySerializer s) Flink内部使用。删除这些属性,你的代码就可以运行了。

相关问题