新闻资讯

质量为本、客户为根、勇于拼搏、务实创新

< 返回新闻资讯列表

如何使用kafka命令查看topic消费情况,kafka简单使用

发布时间:2024-01-25 00:22:17

如何使用kafka命令查看topic消费情况

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

  1. 查看消费者组信息:
kafka-consumer-groups.sh --bootstrap-server <kafka服务器地址> --group <消费者组名称> --describe

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

  1. 查看特定topic的消费者偏移量:
kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list <kafka服务器地址> --topic <topic名称> --time ⑴

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

  1. 查看特定topic的消费者组消费情况:
kafka-consumer-groups.sh --bootstrap-server <kafka服务器地址> --group <消费者组名称> --topic <topic名称> --describe

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

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