如何通过Kafka CLI批量修改多个Topic的最小同步副本数

kafka-configs命令本身不支持直接传入多个--entity-name参数，不过用Shell的简单循环就能搞定批量修改，不需要写复杂的自定义脚本，下面是几种实用方法：

方法一：手动指定Topic列表循环执行 #

把要修改的Topic名称列出来，用for循环逐个跑修改命令：

# 替换成你的ZooKeeper地址
ZOOKEEPER="zookeeper节点:端口"
# 目标配置
TARGET_CONFIG="min.insync.replicas=2"
# 要修改的Topic，用空格分隔
TOPICS="topic_a topic_b topic_c"

for TOPIC in $TOPICS; do
  echo "正在修改Topic: $TOPIC"
  kafka-configs --alter --entity-type topics --entity-name $TOPIC --add-config $TARGET_CONFIG --zookeeper $ZOOKEEPER
done

方法二：从文件读取Topic列表 #

如果Topic数量多，把所有Topic名称写入文本文件（每行一个），再循环读取处理：

ZOOKEEPER="zookeeper节点:端口"
TARGET_CONFIG="min.insync.replicas=2"
# 存放Topic的文件路径
TOPIC_FILE="./need_modify_topics.txt"

while read -r TOPIC; do
  echo "正在修改Topic: $TOPIC"
  kafka-configs --alter --entity-type topics --entity-name "$TOPIC" --add-config $TARGET_CONFIG --zookeeper $ZOOKEEPER
done < "$TOPIC_FILE"

方法三：按规则过滤Topic批量修改 #

如果要修改符合特定命名规则的Topic（比如前缀是order_的所有Topic），可以先列出所有Topic再过滤处理：

ZOOKEEPER="zookeeper节点:端口"
TARGET_CONFIG="min.insync.replicas=2"

# 过滤出前缀为order_的Topic，可根据需求修改grep条件
kafka-topics --list --zookeeper $ZOOKEEPER | grep "^order_" | while read -r TOPIC; do
  echo "正在修改Topic: $TOPIC"
  kafka-configs --alter --entity-type topics --entity-name "$TOPIC" --add-config $TARGET_CONFIG --zookeeper $ZOOKEEPER
done

额外提示 #

• 新版Kafka（2.2以上）推荐用--bootstrap-server替代--zookeeper参数，命令调整为：

  kafka-configs --alter --entity-type topics --entity-name $TOPIC --add-config $TARGET_CONFIG --bootstrap-server kafka节点:端口
  

• 执行前确认自己有修改Topic配置的权限，避免报错

内容的提问来源于stack exchange，提问作者fahadhub