为什么kafka 0.10控制台生产者不能向kafka 0.9发送消息?

lbsnaicq  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(405)

为什么kafka 0.10控制台生产者不能向kafka 0.9发送消息?
我正在0.9版(服务器端)中启动kafka控制台使用者。我将在版本0.10中启动kafka console producer(在客户端)。然后我进入了(下图)。
为什么新的生产者不能向老消费者发送信息呢?有没有可能把新制作人设置成一种不推荐使用的模式来向老Kafka发送消息?
$bin\windows\kafka-console-producer.bat--代理列表我的_server:9092 --topic 我的主题
[2016-08-30 14:03:53365]Kafka生产者i/o线程中的错误未捕获错误:(org.apache.kafka.clients.producer.internals.sender)org.apache.kafka.common.protocol.types.schemaexception:读取字段“brokers”时出错:读取字段“host”时出错:读取长度为25452的字符串时出错,org.apache.kafka.common.protocol.types.schema.read(schema。java:73)在org.apache.kafka.clients.networkclient.parseresponse(networkclient。java:380)在org.apache.kafka.clients.networkclient.handlecompletedreceives(networkclient。java:449)在org.apache.kafka.clients.networkclient.poll(networkclient。java:269)在org.apache.kafka.clients.producer.internals.sender.run(sender。java:229)在org.apache.kafka.clients.producer.internals.sender.run(sender。java:134)在java.lang.thread.run(线程。java:745)

hgncfbus

hgncfbus1#

Kafka0.10.0引入了一种新的消息格式。我不完全确定,但看起来您正在向一个显然对此一无所知的代理发送一条新格式的消息。
您应该尝试强制0.10生产者使用旧的消息格式。您可以在这里找到更多信息:http://kafka.apache.org/documentation.html#upgrade_10_breaking

相关问题