要使用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名稱>
替換為實際的值。