kafka-configs.sh脚本是专门用来对配置进行操作的,这里的操作是指在运行状态下修改原有的配置,如此可以达到动态变更的目的。

kafka-configs.sh脚本使用entity-type参数来指定操作配置的类型,并且使用entity-name参数来指定操作配置的名称。

entity-type的释义 entity-name的释义
主题类型的配置,取值为topics 指定主题的名称
broker类型的配置,取值为brokers 指定brokerId值,即broker中broker.id参数配置的值
客户端类型的配置,取值为clients 指定clientId的值,即KafkaProducer或KafkaConsumer的client.id参数配置的值
用户类型的配置,取值为users 指定用户名

查看主题配置

kafka-configs.sh --bootstrap-server 192.168.94.151:9092 --topic topic-demo01 --all --describe

–all 查看所有配置,不加入此参数查看动态的配置

查看broker配置

kafka-configs.sh --bootstrap-server 192.168.94.151:9092 --all --describe --broker brokerId

修改broker配置

kafka-configs.sh --bootstrap-server 192.168.94.151:9093 --entity-type brokers --entity-name 2 --add-config unclean.leader.election.enable=true  --alter

删除broker动态的配置

kafka-configs.sh --bootstrap-server 192.168.94.151:9093 --entity-type brokers --entity-name 2 --delete-config unclean.leader.election.enable  --alter

修改topic配置

kafka-configs.sh --bootstrap-server 192.168.94.151:9093 --entity-type topics --entity-name topic-demo02  --add-config unclean.leader.election.enable=true  --alter

删除topic动态的配置

kafka-configs.sh --bootstrap-server 192.168.94.151:9095 --entity-type brokers --entity-name 2 --delete-config unclean.leader.election.enable  --alter

实时内容请关注微信公众号,公众号与博客同时更新:程序员星星toC
在这里插入图片描述

Logo

Kafka开源项目指南提供详尽教程,助开发者掌握其架构、配置和使用,实现高效数据流管理和实时处理。它高性能、可扩展,适合日志收集和实时数据处理,通过持久化保障数据安全,是企业大数据生态系统的核心。

更多推荐