你可以使用Kafka自帶的命令行工具kafka-topics.sh
來查看Kafka中特定topic的數(shù)據(jù)量。以下是使用命令行工具來查詢topic數(shù)據(jù)量的步驟:
./bin/kafka-topics.sh --bootstrap-server localhost:9092 --list
這將顯示Kafka中所有可用的topic。./bin/kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list localhost:9092 --topic <topic名稱> --time -1 --offsets 1 | awk -F ":" '{sum += $3} END {print sum}'
將<topic名稱>
替換為你要查詢的topic的名稱。這個命令將返回指定topic的總數(shù)據(jù)量。請注意,以上命令中的localhost:9092
是Kafka服務器的地址和端口號。如果你的Kafka服務器不在本地或使用不同的端口,請相應地修改命令中的地址和端口。