啟動(dòng)命令

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 &

查看一個(gè)topic中有多少數(shù)據(jù)量

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

#創(chuàng)建topic

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

#生產(chǎn)消費(fèi)數(shù)據(jù)

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

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

#? -from-beginning? 從最開(kāi)始消費(fèi)數(shù)據(jù)

#指定消費(fèi)者組

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