kafka 0.10.0.1添加了使用名为kafka-streams-application-reset.sh的脚本重置kafka streams应用程序的功能
confluent在这里有一些关于这个脚本的好文档。
很遗憾,在本地运行脚本会导致错误:
$ bin/kafka-streams-application-reset --application-id my-streams-app \
--input-topics my-input-topic \
--intermediate-topics rekeyed-topic \
--bootstrap-servers brokerHost:9092 \
--zookeeper zookeeperHost:2181
# output
ERROR: Request GROUP_COORDINATOR failed on brokers List(...)
此外,代理日志中还会显示以下行:
kafka.network.InvalidRequestException: Error getting request for apiKey: 3 and apiVersion: 2
据我所知,看起来客户端发出的请求无效,但我不确定为什么会发生这种情况。我们的代理仍然使用0.9.0,所以我不确定这是否是问题所在,但它似乎是基于 apiKey
代理日志中的值。
有人能告诉我为什么会发生这种情况以及如何解决吗?
1条答案
按热度按时间s4chpxco1#
kafka streams基于版本0.10,不适用于0.9。
同样的情况也适用于
bin/kafka-streams-application-reset
工具。它使用0.10KafkaClient
内部和需要一个0.10经纪人。一般来说,只有Kafka经纪人而不是Kafka客户是向后兼容的,即经纪人确实与老客户合作,但客户不与老经纪人合作。这可能会在将来有所改善。请参阅kip-97:改进的kafka客户端rpc兼容性策略
错误消息——即使不是很有描述性,也很难理解——告诉您尝试连接到一个不理解新客户机的代理。