apache-kafka - kafka 消费者组在 0.11 3.0.0 版本上失败

Question

在 kafka 0.11 版本上运行脚本时遇到此错误

Error: Executing consumer group command failed due to The broker only supports OffsetFetchRequest v1, but we need v2 or newer to request all topic partitions.

依赖关系
编译 'org.apache.kafka:kafka_2.11:0.11.0-kafka-3.0.0'

命令

./kafka-consumer-groups.sh  --new-consumer --describe --bootstrap-server bootstrap:9092 --group myid

知道如何解决这个问题吗？

Answer 1

错误似乎非常明显 - 您正在使用的代理版本和客户端库之间存在不匹配。 根据Kafka source ，当代理向后级别(版本 < 2)并且您尝试检索所有分区的偏移量信息时，会引发此异常。