kafka常用命令,啟動/停止/查看主題列表/消費/生產


kafka啟動(需要先啟動zk):

bin/zookeeper-server-start.sh -daemon config/zookeeper.properties 
bin/kafka-server-start.sh -daemon config/server.properties 

 

kafka停止:

bin/kafka-server-stop.sh 
bin/zookeeper-server-stop.sh 

 

把以下內容追加到bashrc中。

以centos為例:

vi ~/.bashrc

追加內容如下:

復制代碼
KAFKA_HOME="/usr/lib/kafka"
KAFKA_ADDRESS="192.168.108.136"
KAFKA_BIND="${KAFKA_ADDRESS}:9092"
ZK_BIND="${KAFKA_ADDRESS}:2181"

alias listtopics="${KAFKA_HOME}/bin/kafka-topics.sh --list --zookeeper ${ZK_BIND} "
alias createtopic="${KAFKA_HOME}/bin/kafka-topics.sh --create --zookeeper ${ZK_BIND} --replication-factor 1 --partitions 1 --topic "
alias kafkaproduce="${KAFKA_HOME}/bin/kafka-console-producer.sh --broker-list ${KAFKA_BIND} --topic "
alias kafkaconsume="${KAFKA_HOME}/bin/kafka-console-consumer.sh --zookeeper ${ZK_BIND} --from-beginning --topic "
alias kafkaconsumekey="${KAFKA_HOME}/bin/kafka-console-consumer.sh --zookeeper ${ZK_BIND} --from-beginning --property print.key=true --property key.separator=' --- ' --topic "
alias kafkaconsumeoffset="${KAFKA_HOME}/bin/kafka-console-consumer.sh --zookeeper ${ZK_BIND} --from-beginning --print-offsets --topic"
復制代碼

 

保存后使其生效

source ~/.bashrc

 

查看kafka主題:

listtopics

創建kafka主題parasis:

createtopic parasis

在parasis主題下生產數據,進入命令行后,輸入生產數據,以回車結尾:

kafkaproduce parasis

消費parasis主題內數據:

kafkaconsume parasis

消費parasis主題內數據(包含key):

kafkaconsumekey parasis

消費parasis主題內數據(包含offset):

kafkaconsumeoffset parasis


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM