为什么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]错误kafka 生产环境 者I / O线程中的未捕获错误：（org.apache.kafka.clients.producer.internals.Sender）org.apache.kafka.common.protocol.types . SchemaException：读取字段'broker'时出错：读取字段'host'时出错：读取长度为25452的字符串时出错，org.apache.kafka.common.protocol.types.Schema.read中只有69字节可用（Schema.java:73） org.apache.kafka.clients.NetworkClient.parseResponse（NetworkClient.java:380）位于org.apache.kafka.clients.NetworkClient.poll的org.apache.kafka.clients.NetworkClient.handleCompletedReceives（NetworkClient.java:449） （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）at java.lang.Thread.run（Thread.java:745）
1 回答
Kafka 0.10.0引入了一种新的消息格式 . 我不完全确定，但看起来你正在向一个清楚地一无所知的经纪人发送带有新格式的消息 .
您应该尝试强制0.10生成器使用旧的消息格式 . 在这里您可以找到更多信息：http://kafka.apache.org/documentation.html#upgrade_10_breaking