kafka常用命令记录 ​

环境信息：MacOS 13.4.1

Kafka版本：Homebrew Kafka_3.4.0

topic ​

新建topic ​

kafka-topics --create --topic topic-name --partitions 4 --replication-factor 2 --bootstrap-server localhost:9092

查看所有topic ​

kafka-topics --bootstrap-server 127.0.0.1:9092 --list

查看topic信息 ​

kafka-topics --bootstrap-server 127.0.0.1:9092 --describe --topic topic-name

修改topic分区数 ​

kafka-topics --bootstrap-server 127.0.0.1:9092 --alter --partitions 2 --topic topic-name

删除topic ​

kafka-topics --bootstrap-server 127.0.0.1:9092 --delete --topic topic-name

消费者组 ​

查看所有消费者组 ​

kafka-consumer-groups --bootstrap-server 127.0.0.1:9092 --list

查看消费者组详情 ​

kafka-consumer-groups --bootstrap-server 127.0.0.1:9092 --describe --group topic-name

查看消费者组里具体成员 ​

kafka-consumer-groups --bootstrap-server 127.0.0.1:9092 --describe --members --group topic-name

消费者console ​

查看topic中的所有消息 ​

kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic topic-name --from-beginning

指定分区、offset的消息 ​

kafka-console-consumer --bootstrap-server 127.0.0.1:9092 --topic topic-name --partition 0 --offset 1