kafka 6 常用命令彙總

#/usr/local/zookeeper/bin/zkserver.sh start /usr/local/zookeeper/conf/zoo.cfg

#/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server0.properties

#zkcli.sh ls /brokers/ids

集群之間拷貝資料：

bin/kafka-run-class.sh kafka.tools.mirrormaker

–consumer.config consumer-1.properties

–consumer.config consumer-2.properties

–producer.config producer.properties

–whitelist your-topic

#kafka-topics.sh --list --zookeeper pda1:2181

kafka-topic.sh --create

--zookeeper pda1:2181
--replication-factor 1
--partitions 1
--topic test

#kafka-topics.sh --describe --zookeeper myname:2181 --topic test【檢視topic詳細資訊】

#kafka-topics.sh --delete --zookeeper myname:2181 --topic test【刪除topic】

#kafka-console-producer.sh --broker-list myname:9092 --topic test【啟動控制台生產者】

#kafka-console-consumer.sh --bootstrap-server myname:9092 --topic test --from-beginning【啟動控制台消費者】

kafka在0.9.0.0版本之後，kafka.tools.consumeroffsetchecker已經不支援了。

應該使用kafka.admin.consumergroupcommand

(或bin/kafka-consumer-groups.sh指令碼)來管理消費者組

#kafka-consumer-groups.sh --bootstrap-server myname:9092 --list檢視所有組

#kafka-consumer-groups.sh --bootstrap-server myname:9092 --describe --group groupname檢視具體組的詳細描述資訊

kafka常用命令

kafka常用操作命令 l檢視當前伺服器中的所有topic bin kafka topics.sh list zookeeper hadoop02 2181 l建立topic kafka topics.sh create zookeeper hadoop02 2181 replication fac...

kafka常用命令

啟動集群 nohup bin kafka server start.sh config server.properties 建立topic kafka topics topictt replication factor3 partitions3 create zookeeper hadoop1 21...

Kafka 常用命令

kafka console producer broker list 127.0.0.1 9092 topic mytopic kafka console consumer bootstrap server 127.0.0.1 9092 topic mytopic 建立主題,replication ...