第 3 章 · Web 版 kafka-cli

命令速查

Topic 管理

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

kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --create --topic learn.03.demo --partitions 3 --replication-factor 1

kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --describe --topic learn.03.demo

kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --alter --topic learn.03.demo --partitions 6

kafka-topics.sh --bootstrap-server 127.0.0.1:9092 --delete --topic learn.03.demo

收发消息

kafka-console-producer.sh --bootstrap-server 127.0.0.1:9092 --topic learn.03.demo

kafka-console-producer.sh --bootstrap-server 127.0.0.1:9092 --topic learn.03.demo --property parse.key=true --property key.separator=:

kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic learn.03.demo --from-beginning

kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic learn.03.demo --group team-A

kafka-console-consumer.sh --bootstrap-server 127.0.0.1:9092 --topic learn.03.demo --partition 1 --offset earliest --max-messages 3

消费组与 Offset

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

kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group team-A

kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --describe --group team-A --members --verbose

kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group team-A --topic learn.03.demo --reset-offsets --to-earliest --dry-run

kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --group team-A --topic learn.03.demo --reset-offsets --to-earliest --execute

kafka-consumer-groups.sh --bootstrap-server 127.0.0.1:9092 --delete --group team-A

动态配置

kafka-configs.sh --bootstrap-server 127.0.0.1:9092 --entity-type topics --entity-name learn.03.demo --describe --all

kafka-configs.sh --bootstrap-server 127.0.0.1:9092 --entity-type topics --entity-name learn.03.demo --alter --add-config retention.ms=3600000

存储观察

kafka-dump-log.sh --files /tmp/kraft-combined-logs/learn.03.demo-0/00000000000000000000.log --print-data-log

kafka-log-dirs.sh --bootstrap-server 127.0.0.1:9092 --describe

小工具

help

clear

reset-state

[kafka-sandbox]