kafak 命令使用

本篇文章主要內容：

kafka經常使用命令總結

 

一.kafka經常使用命令總結：

1.建立topic

bin/kafka-topics.sh --create --zookeeper ip:port/chroot --replication-factor num --partitions num --topic topic-name
ip:port/chroot－> kafka的zookeeper地址

num －> 數量

topic-name －> topic的名稱

注：向kafka發送數據以前不必定要事先建立topic，能夠直接指定topic發送數據。

2.向kafka發送數據

bin/kafka-console-producer.sh --broker-list broker-ip:port --topic topic-name
broker-ip:port －> broker地址

注：執行完此命令，能夠直接在終端輸入數據，按回車鍵發送，ctrl－c退出。

3.從kafka讀取數據

＃首先是跟讀模式

bin/kafka-console-consumer.sh --zookeeper ip:port/chroot --topic topic-name

能夠讀取到實時發送到kafka的數據，不能讀取到歷史數據。


＃從開始偏移量（offset）讀取數據

bin/kafka-console-consumer.sh --zookeeper ip:port/chroot --topic topic-name --from-beginning

從topic起始位置開始讀取。

4.查看kafkaz中 topic的列表

bin/kafka-topics.sh --list --zookeeper  ip:port/chroot

5.查看某一個topic的詳細信息

bin/kafka-topics.sh --describe --zookeeper ip:port/chroot --topic topic-name

6.  查看topic的消費偏移量

bin/kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper  ip:port/chroot --group group-name

注：實際log消息數量和group下消費的偏移量均可以查看到

 

 

其它命令  點擊這裏