我有一个Kafka生产商在一台机器上使用0.80Kafka版本（例如，ip是1.2.3.4），我可以使用另一台机器上使用0.10Kafka版本的Kafka消费者来使用消息吗？
我试着在听1.2.3.4:9092的更新版本上编写一个消费者。但是上面写着kafka.errors.nobrokersavable:nobrokersavable。这是不允许的吗？还是我搞错了什么？
谢谢。
我有一个Kafka生产商在一台机器上使用0.80Kafka版本（例如，ip是1.2.3.4），我可以使用另一台机器上使用0.10Kafka版本的Kafka消费者来使用消息吗？
我试着在听1.2.3.4:9092的更新版本上编写一个消费者。但是上面写着kafka.errors.nobrokersavable:nobrokersavable。这是不允许的吗？还是我搞错了什么？
谢谢。
1条答案
按热度按时间b5buobof1#
版本0.10.2的客户端可以与版本0.10.0或更新的代理对话。但是，如果您的代理的版本早于0.10.0，则必须在升级客户端之前升级kafka集群中的所有代理。版本0.10.2代理支持0.8.x和更新的客户端。
https://kafka.apache.org/documentation/#upgrade_10_2_0