前言
收集一些在終端下操作kafka的常用命令。
常用命令
切換到kafka目錄進(jìn)行操作
cd /opt/kafka
創(chuàng)建topic
./bin/kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --partitions 3 --replication-factor 2 --topic test
查看所有的topic
./bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181
查看指定的topic
./bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181 --topic test
查看指定topic詳情（分區(qū)糠聪、備份等）
./bin/kafka-topics.sh --describe --zookeepe 127.0.0.1:2181 --topic test
修改topic的partition
./kafka-topics.sh --alter --topic topic1 --zookeeper 127.0.0.1:2181 --partitions 6
往某topic生產(chǎn)消息
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
從某topic消費(fèi)消息
bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic test --from-beginning #（默認(rèn)用一個(gè)線程消費(fèi)指定topic的所有分區(qū)的數(shù)據(jù)）
topic 分區(qū)擴(kuò)容 修改為10個(gè)分區(qū)
bin/kafka-topics.sh --zookeeper localhost:2181 -alter --partitions 10 --topic test1
查詢消費(fèi)組
bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --list
查看消費(fèi)者信息
bin/kafka-consumer-groups.sh --zookeeper localhost:2181 --describe test
修改topic日志保留時(shí)間(毫秒)
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic test --config retention.ms=43200000
