kafka streams-kafka-streams-application-reset.sh发送错误的api版本

drkbr07n  于 2021-06-07  发布在  Kafka
关注(0)|答案(1)|浏览(507)

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 代理日志中的值。
有人能告诉我为什么会发生这种情况以及如何解决吗?

s4chpxco

s4chpxco1#

kafka streams基于版本0.10,不适用于0.9。
同样的情况也适用于 bin/kafka-streams-application-reset 工具。它使用0.10 KafkaClient 内部和需要一个0.10经纪人。
一般来说,只有Kafka经纪人而不是Kafka客户是向后兼容的,即经纪人确实与老客户合作,但客户不与老经纪人合作。这可能会在将来有所改善。请参阅kip-97:改进的kafka客户端rpc兼容性策略
错误消息——即使不是很有描述性,也很难理解——告诉您尝试连接到一个不理解新客户机的代理。

相关问题