Apache Kafka常用命令

1.查看topic詳細(xì)信息

./kafka-topics.sh -zookeeper ip:port -describe -topic topicname
kafka/bin/kafka-topics.sh -zookeeper hostname:2181 -describe -topic topicname
2.為topic增加副本

./kafka-reassign-partiotions.sh -zookeeper ip:port -reassignment-json-file
json/partitions-to-move.json -execute
kafka/bin/kafka-reassign-partitions.sh -zookeeper hostname:2181
-reassignment-json-file json/partitions-to-move.json -execute
3.創(chuàng)建topic

./kafka-topics.sh --create --zookeeper ip:port --replication-factor 1
--partitions 1 --topic topicname
kafka/bin/kafka-topics.sh --create --zookeeper hostname:2181
--replication-factor 1 --partitions 1 --topic topicname
4.為topic增加partition

./bin/kafka-topics.sh -zookeeper ip:port -alter -partitions 20 -topic topicname
kafka/bin/kafka-topics.sh --zookeeper hostname:2181 -alter -partitions 6
-topic topicname
5.Kafka生產(chǎn)者客戶端命令

./kafka-console-producer.sh --broker-list ip:port --topic topicname
kafka/bin/kafka-console-producer.sh --broker-list
hostname1:9092,hostname2:9092 --topic topicname
6.Kafka消費(fèi)者客戶端命令

./kafka-console-consumer.sh -zookeeper ip:port --topic topicname
./kafka-console-consumer.sh -zookeeper ip:port --from-beginning --topic
topicname
kafka/bin/kafka-console-consumer.sh -zookeeper hostname:2181 --from-beginning
--topic topicname
7.Kafka服務(wù)啟動(dòng)

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

8.下線broker

./kafka-run-class.sh kafka.admin.ShutdownBroker --zookeeper ip:port --broker
#brokerId# --run.retries 3 --retry.interval.ms 60 shutdown broker

9.刪除topic

./kafka-run-class.sh kafka.admin.DeleteTopicCommand --topic
topicname--zookeeper ip:port ./kafka-topics.sh --zookeeper ip:port --delete
--topic topicname
./kafka-topics.sh --delete --zookeeper ip:port --topic topicname
kafka/bin/kafka-topics.sh --delete --zookeeper hostname:2181 --topic topicname
10.查看consumer組內(nèi)消費(fèi)的offset

./kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --zookeeper ip:port
--group test --topic topicname

11.查看消費(fèi)

./kafka-topics.sh --zookeeper ip:port --describe --topic topicname
kafka/bin/kafka-topics.sh --zookeeper hostname:2181 --describe --topic
topicname
12.查找Kafka版本
find / -name \*kafka_\*|head -1|grep -o '\kafka[^\n]*'

• ? 上一篇： web前端干貨之web前端開發(fā)框架匯總
• ? 下一篇：園齡10年，有些新認(rèn)識(shí)跟大家分享