故事

Appearance

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