版本号：kafka_2.12-3.7.0
说明：如有多个地址，用逗号分隔
创建主题

bin/kafka-topics.sh --bootstrap-server localhost:9092 --create --topic demo --partitions 1 --replication-factor 1

删除主题

bin/kafka-topics.sh  --delete --bootstrap-server localhost:9092 --topic demo

查看所有主题

bin/kafka-topics.sh  --list  --bootstrap-server localhost:9092 

查看单个主题详细

bin/kafka-topics.sh  --bootstrap-server localhost:9092  --describe --topic test

查看所有消费组

bin/kafka-consumer-groups.sh --bootstrap-server  localhost:9092 --list

查看单个消费组情况

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe  --group test_group

删除消费组

bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --delete --group test_group

数据保留时间

bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter --entity-type topics --entity-name test --add-config retention.ms=3600000

参数解释：

• --bootstrap-server localhost:9092：指定 Kafka broker 地址。
• --alter：表示你要修改现有的配置。
• --entity-type topics：指定要修改的对象类型是 topic。
• --entity-name test：指定要修改的主题名称，这里是 test。
• --add-config retention.ms=3600000：设置 retention.ms 配置为 3600000 毫秒（1小时）。