Kafka3.x KRaft 模式 (没有zookeeper) 常用下令

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

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

复制代码

删除主题

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

复制代码

查看所有主题

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

复制代码

查看单个主题详细

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

复制代码

查看所有消费组

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

复制代码

查看单个消费组环境

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

复制代码

删除消费组

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

复制代码

数据保存时间

1. 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小时）。
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。