建立topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
檢視所有topic
bin/kafka-topics.sh --list --zookeeper localhost:2181
寫入topik資料
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
檢視topic中的資料
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning
啟動kafka
啟動zookeeper
啟動kafka 之前需要先啟動zookeeper 否則會報錯
啟動命令：./bin/zookeeper-server-start.sh -daemon config/zookeeper.properties
-daemon：表示以守護程序的方式啟動。
啟動 kafka
啟動命令：./bin/kafka-server-start.sh -daemon config/server.properties
kafka基本命令使用
本文主要參考 最近開始接觸kafka，下面介紹介紹一些最基本的kafka 的操作。首先是啟動kafka。kafka依賴zookeeper，所以需要先啟動zookeeper。bin zookeeper server start.sh config zookeeper.properties然後啟動kaf...
kafka基本命令（速記）
usr local cellar kafka 1.1.0 1.1.0版本目錄，請檢視自己版本對應的目錄號 usr local etc kafka server.properties usr local etc kafka zookeeper.properties cd usr local cella...
kafka2 5 0基本命令
本博文所使用kafka版本2.5.0，作業系統centos8.1 啟動zookeeper 演示用的話，直接啟動kafka自帶的zookeeper即可 cd kafkadirectory kafka 2.12 2.5.0 bin zookeeper server start.sh config zoo...