我使用kafka连接器连接到mq，所有安装都成功，mq中的消息如预期的那样流向kafka。但是我在消费者控制台中看到的消息是另一种格式，我不明白！我把纯文本信息（例如- Hi )在mq上用这种格式在Kafka上 [B@90e44060 如何将纯文本转换为纯文本消息？
Hi
[B@90e44060
hc2pp10m1#
以解决此问题 mq-source.properties 文件设置如下：
mq-source.properties
key.converter=org.apache.kafka.connect.converters.ByteArrayConverter value.converter=org.apache.kafka.connect.converters.ByteArrayConverter
1条答案
按热度按时间hc2pp10m1#
以解决此问题
mq-source.properties文件设置如下：