kafka调试常用命令

xiaoxiao2021-02-28 121

1、创建topic

./kafka-topics.sh --zookeeper 10.77.4.27:2181/kafka --create --topic z3dbus_search_test03 --partitions 1 --replication-factor 2

2、查看某个topic在某个分区上的记录数

./kafka-run-class.sh kafka.tools.GetOffsetShell --topic quant_backtest --broker-list 10.77.4.28:9092 --partitions 0

3、查看某个topic的消费者情况

./kafka-consumer-groups.sh --bootstrap-server 10.77.4.27:9092 --describe --group quant_test

转载请注明原文地址: https://www.6miu.com/read-26603.html

技术

最新回复(0)