java - 为什么kafka 0.10控制台生产者无法向kafka 0.9发送消息？

Question

为什么kafka 0.10控制台生产者无法向kafka 0.9发送消息？

我正在0.9版本中启动kafka控制台消费者(在服务器端)。我正在 0.10 版本(在客户端)启动 kafka 控制台生成器。然后我遇到了生产者异常(如下)。

为什么新的生产者无法向旧的消费者发送消息？是否可以将新的生产者设置为一种已弃用的模式来向旧的kafka发送消息？

$ bin\windows\kafka-console- Producer.bat --broker-list my_server:9092 --topic my_topic

[2016-08-30 14:03:53,365] ERROR kafka 生产者 I/O 线程中 Uncaught Error :(org.apache.kafka.clients. Producer.internals.Sender)org.apache.kafka.common.protocol.types.SchemaException:读取字段“brokers”时出错:读取字段“host”时出错:读取长度为 25452 的字符串时出错，只有 69 个字节可用 在 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(Thread.java:745)

Answer 1

Kafka 0.10.0 引入了新的消息格式。我不完全确定，但看起来您正在向一个显然对此一无所知的经纪人发送一条采用新格式的消息。

您应该尝试强制 0.10 生产者使用旧的消息格式。在这里您可以找到更多信息:http://kafka.apache.org/documentation.html#upgrade_10_breaking