Kafka3.x KRaft 模式 (没有zookeeper) 常用下令
版本号: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-serverlocalhost: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小时)。
免责声明:如果侵犯了您的权益,请联系站长,我们会及时删除侵权内容,谢谢合作!更多信息从访问主页:qidao123.com:ToB企服之家,中国第一个企服评测及商务社交产业平台。
页:
[1]