kafka-kafka-consumer-groups.sh——descripe不返回消费组的输出

eeq64g8w 于 2021-06-04 发布在 Kafka

关注(0)|答案(1)|浏览(826)

Kafka1.1版 --list 可以得到消费者群体

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list --command-config config/client_security.properties
Note: This will not show information about old Zookeeper-based consumers.

spark-kafka-source-fd469ba1-6ffa-43cb-8919-06c45ae56fd6--724816166-driver-0
console-consumer-23379
console-consumer-44846
console-consumer-75221
console-consumer-57833
yizhisec-traffic
console-consumer-91940
group1

无法获取任何信息。此消费者组id由spark生成。

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group spark-kafka-source-fd469ba1-6ffa-43cb-8919-06c45ae56fd6--724816166-driver-0  --command-config config/client_security.properties

一无所获

Note: This will not show information about old Zookeeper-based consumers.

但测试其他消费者的工作。

更新更多详细信息

我使用结构化流Kafka

当我使用zookeeper查询get error时

bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe --group spark-kafka-source-fd469ba1-6ffa-43cb-8919-06c45ae56fd6--724816166-driver-0  --command-config config/client_security.properties

获取错误

Note: This will only show information about consumers that use ZooKeeper (not those using the Java consumer API).
Error: The consumer group 'spark-kafka-source-fd469ba1-6ffa-43cb-8919-06c45ae56fd6--724816166-driver-0' does not exist.

apache-kafka apache-spark spark-streaming kafka-consumer-api spark-streaming-kafka

来源：https://stackoverflow.com/questions/61204939/kafka-kafka-consumer-groups-sh-describe-returns-no-output-for-a-consumer-group

1条答案

按热度按时间

6qqygrtg1#

kafka-consumer-groups \
  --bootstrap-server localhost:9092 \
  --describe \
  --group your_consumer_group_name

如果使用者群组中的使用者尚未提交任何补偿，则不会传回任何输出。
如果

bin/kafka-consumer-groups.sh \
  --bootstrap-server localhost:9092 \
  --describe \
  --group spark-kafka-source-fd469ba1-6ffa-43cb-8919-06c45ae56fd6--724816166-driver-0 \
  --command-config config/client_security.properties

以及

bin/kafka-consumer-groups.sh \
  --bootstrap-server localhost:9092 \
  --new-consumer
  --describe \
  --group spark-kafka-source-fd469ba1-6ffa-43cb-8919-06c45ae56fd6--724816166-driver-0 \
  --command-config config/client_security.properties

匹配和消费组出现在两个消费组列表输出中，我猜是你的消费组里面的消费组 spark-kafka-source-fd469ba1-6ffa-43cb-8919-06c45ae56fd6--724816166-driver-0 没有提交任何偏移量，这就是为什么没有使用describe命令显示信息的原因。
确保你的消费者 spark-kafka-source-fd469ba1-6ffa-43cb-8919-06c45ae56fd6--724816166-driver-0 成功提交其偏移量（手动或自动）。

赞(0）回复(0）举报 2021-06-04

我来回答

kafka-kafka-consumer-groups.sh——descripe不返回消费组的输出

更新更多详细信息

1条答案

相关问题

热门标签

最新问答