使用 KafkaConsumer 0.10.0 读取 0.9.0 消息？
Read 0.9.0 messages with KafkaConsumer 0.10.0?
是否可以从 KafkaConsumer 版本为 0.10.0 的 0.9.0 代理读取消息？
阅读文档后，我看到了有关如何以继续使用现有日志的方式将代理从 0.9 升级到 0.10 的说明。甚至可以指示代理向老消费者发送 0.9 条消息。
但我正在寻找相反的方式：新消费者，旧经纪人。
天真地尝试，我得到一个例外：
org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'topic_metadata': Error reading array of size 1142898, only 2701 bytes available
有没有办法告诉 0.10.0 消费者期待旧式消息？
前段时间我在 Kafka Jira 中打开了一个类似的问题并得到了一个非常明确的答案 - 首先升级代理，然后是客户端，反之亦然。这可确保实现处理您的请求所需的所有功能，并且代理可以妥善处理它。
如果您对详细信息感兴趣，这是我打开的问题的 link - https://issues.apache.org/jira/browse/KAFKA-2496。
是否可以从 KafkaConsumer 版本为 0.10.0 的 0.9.0 代理读取消息？
阅读文档后，我看到了有关如何以继续使用现有日志的方式将代理从 0.9 升级到 0.10 的说明。甚至可以指示代理向老消费者发送 0.9 条消息。
但我正在寻找相反的方式：新消费者，旧经纪人。
天真地尝试，我得到一个例外：
org.apache.kafka.common.protocol.types.SchemaException: Error reading field 'topic_metadata': Error reading array of size 1142898, only 2701 bytes available
有没有办法告诉 0.10.0 消费者期待旧式消息？
前段时间我在 Kafka Jira 中打开了一个类似的问题并得到了一个非常明确的答案 - 首先升级代理，然后是客户端，反之亦然。这可确保实现处理您的请求所需的所有功能，并且代理可以妥善处理它。
如果您对详细信息感兴趣，这是我打开的问题的 link - https://issues.apache.org/jira/browse/KAFKA-2496。