啟動kafka(到每個節點啟動)
node01： nohup ./bin/kafka-server-start.sh config/server.properties &
node02： nohup ./bin/kafka-server-start.sh config/server.properties &
node03s： nohup ./bin/kafka-server-start.sh config/server.properties &
建立topic
bin/kafka-topics.sh --create --zookeeper node01:2181,node02:2181,node03:2181 --replication-factor 2 --partitions 3 --topic 18bd34
查詢topic
bin/kafka-topics.sh --list --zookeeper node01:2181,node02:2181,node03:2181
生產資料
bin/kafka-console-producer.sh --broker-list node01:9092,node02:9092,node03:9092 --topic 18bd34
--broker-list 表示儲存資料的伺服器
模擬消費者，消費資料
bin/kafka-console-consumer.sh --zookeeper node01:2181,node02:2181,node03:2181 --topic 18bd34 --from-beginning
--from-beginning 表示從頭開始消費
--zookeeper 作用是記錄資料消費到的位置（資料消費到了**/第幾條）
刪除topic
bin/kafka-topics.sh --zookeeper node01:2181,node02:2181,node03:2181 --delete --topic 18bd34_1
新增配置
bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic test --config flush.messages=1
刪除配置
bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic test --delete-config flush.messages
修改分割槽
bin/kafka-topics.sh --zookeeper zkhost:port --alter --topic topicname --partitions 8
kafka相關操作命令
1 開啟zookeeper集群 startzk.sh 2 開啟kafka集群 start kafka.sh 3 開啟kafka視覺化介面 kafka manager start kafka manager.sh 4 生產者操作 kafka console producer.sh broker lis...
kafka相關命令
1.群起指令碼 bin bash case 1 in start stop esac 2.檢視主題 bin kafka topics.sh list zookeeper k8smaster 2181 3.建立主題 kafka topics.sh create zookeeper k8smaster ...
kafka命令列操作，topic相關命令
檢視當前伺服器中的所有topic bin kafka topics.sh zookeeper 主機 2181 list 建立topic bin kafka topics.sh zookeeper 主機 2181 create replication factor 3 partitions 1 top...