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