一、配置管理

在运行状态下，可以使用kafka-configs.sh脚本修改原有的配置，如此可以达到动态变更的目的。

其中kafka-configs.sh脚本包含两种指令类型：

• alter：变更配置
• describe：查看配置

另外，kafka-configs.sh支持的配置类型包括四种：

• 主题配置
• broker
• 用户
• 客户端

因此，对于一条配置命令，应该包括三个方面：

• 指令动作：变更 or 查看
• 指令操作对象类型：主题 or broker or 用户 or 客户端
• 指令操作对象名称：对于指令操作对象的名称

二、查看配置

bin/kafka-configs.sh --bootstrap-server localhost:9092 --describe --entity-type topics --entity-name quickstart-events

• --describle：指定了配置的指令操作
• --entity-type：指定了查看配置的实体类型
• --entity-name：指定了查看配置的实体名称

其中，配置的实体类型和配置的实体名称对应关系如下：

entity-type	entity-name
topics（主题）	主题的名称
clients（客户端）	指定 clientId 值，即 KafkaProducer 或 KafkaConsumer 的 client.id 参数配置的值
users（用户）	指定用户名
broker	指定 brokerId 值，即 broker 中 broker.id 参数配置的值

三、变更配置

使用 alter 指令变更配置时，需要配合 add-config 和 delete-config 这两个参数一起使用：

• add-config：增加、修改配置
• delete-config：删除配置

修改操作

bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter --entity-type topics --entity-name quickstart-events --add-config  cleanup.policy=compact,max.message.bytes=10000

# 查看
bin/kafka-configs.sh --bootstrap-server localhost:9092 --describe --entity-type topics --entity-name quickstart-events
Dynamic configs for topic quickstart-events are:
  cleanup.policy=compact sensitive=false synonyms={DYNAMIC_TOPIC_CONFIG:cleanup.policy=compact, DEFAULT_CONFIG:log.cleanup.policy=delete}
  max.message.bytes=10000 sensitive=false synonyms={DYNAMIC_TOPIC_CONFIG:max.message.bytes=10000, DEFAULT_CONFIG:message.max.bytes=1048588}

• --alter：指令类型
• --entity-type：指令操作对象类型
• --entity-name：指令操作对象名称
• --add-config：修改配置

删除操作

bin/kafka-configs.sh --bootstrap-server localhost:9092 --alter --entity-type topics --entity-name quickstart-events --delete-config  cleanup.policy,max.message.bytes

• --alter：指令类型
• --entity-type：指令操作对象类型
• --entity-name：指令操作对象名称
• --delete-config：删除配置

参考

官方文档 (opens new window)

图解Kafka之实战指南 (opens new window)