怎么使用kafka命令查看topic消费情况-开发者知识库平台

怎么使用kafka命令查看topic消费情况

kafka

1188

2024/2/2 0:22:17

栏目: 编程语言

要使用Kafka命令查看topic的消费情况，可以使用以下命令：

kafka-consumer-groups.sh --bootstrap-server <kafka服务器地址> --group <消费者组名称> --describe

这将显示给定消费者组的消费者的详细信息，包括当前消费的topic、消费的偏移量等。

kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list <kafka服务器地址> --topic <topic名称> --time -1

这将显示给定topic的每个分区的消费者偏移量。

kafka-consumer-groups.sh --bootstrap-server <kafka服务器地址> --group <消费者组名称> --topic <topic名称> --describe

这将显示给定消费者组在特定topic上的消费情况，包括每个消费者的偏移量和lag（与最新消息的偏移量之差）。

请确保将<kafka服务器地址>、<消费者组名称>和<topic名称>替换为实际的值。

怎么使用kafka命令查看topic消费情况