Skip to content

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

清空topic的消息

给topic保留消息时间改为1s,然后等topic中的消息被自动删除,再删除该配置

删除topic也可以实现清空消息

kafka-configs --bootstrap-server 127.0.0.1:9092 --entity-type topics --alter --entity-name example --add-config retention.ms=1000

kafka-configs --bootstrap-server 127.0.0.1:9092 --entity-type topics --alter --entity-name example --delete-config retention.ms

消费者组

查看所有消费者组

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