kafka常用操作命令
l檢視當前伺服器中的所有topic
bin/kafka-topics.sh --list --zookeeper hadoop02:2181
l建立topic
./kafka-topics.sh --create --zookeeper hadoop02:2181 --replication-factor 1 --partitions 3 --topic first
l刪除topic
sh bin/kafka-topics.sh --delete --zookeeper hadoop02:2181 --topic test
需要server.properties中設定delete.topic.enable=true否則只是標記刪除或者直接重啟。
l通過shell命令傳送訊息
kafka-console-producer.sh --broker-list hadoop02:9092 --topic beicai
l通過shell消費訊息
sh bin/kafka-console-consumer.sh --zookeeper hadoop02:2181 --from-beginning --topic test1
l檢視消費位置
sh kafka-run-class.sh kafka.tools.consumeroffsetchecker --zookeeper hadoop02:2181 --group testgroup
l檢視某個topic的詳情
sh kafka-topics.sh --topic test --describe --zookeeper hadoop02:2181
啟動flume前台命令：
在輸入[hadoop@hadoop02 conf]$ flume-ng agent -n a -c conf -f /log.conf
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 ...
kafka常用命令
啟動kafka bin kafka server start.sh daemon opt kafka config server.properties 關閉kafka kill 9 程序號 kafka建立topic bin kafka topics.sh create zookeeper 12.13...