溫馨提示×

怎么使用kafka命令查看topic消費情況

小億
2005
2024-01-25 00:22:17
欄目: 編程語言

要使用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 -1

這將顯示給定topic的每個分區的消費者偏移量。

  1. 查看特定topic的消費者組消費情況:
kafka-consumer-groups.sh --bootstrap-server <kafka服務器地址> --group <消費者組名稱> --topic <topic名稱> --describe

這將顯示給定消費者組在特定topic上的消費情況,包括每個消費者的偏移量和lag(與最新消息的偏移量之差)。

請確保將<kafka服務器地址>、<消費者組名稱><topic名稱>替換為實際的值。

0
亚洲午夜精品一区二区_中文无码日韩欧免_久久香蕉精品视频_欧美主播一区二区三区美女