kafka常用命令

启动命令

zookeeper QuorumPeerMain ./zkServer.sh start ../conf/zoo.cfg

kafka  kafka  ./kafka-server-start.sh ../config/server.properties &

kafka-manager  ProdServerStart      nohup ./kafka-manager -Dconfig.file=../conf/application.conf  -Dhttp.port:8080 &

查看一个topic中有多少数据量

kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list slave3:9092 --topic aiops-anomaly-kpi --time -1

#查看topic

kafka-topics.sh --zookeeper node01:2181 --list

#查看指定topic

kafka-topics.sh --zookeeper node01:2181 --describe --topic t_ctre

#创建topic

kafka-topics.sh --create  --zookeeper master:2181,slave1:2181,slave2:2181 --topic name --partitions 3 --replication-factor 3

#生产消费数据

kafka-console-consumer.sh  --bootstrap-server master:9092  --topic name

kafka-console-producer.sh --broker-list master:9092 --topic name

#  -from-beginning  从最开始消费数据

#指定消费者组

kafka-console-consumer.sh --bootstrap-server slave3:9092 --topic test--consumer.config /home/opt/kafka/config/consumer.properties