如何利用Ansible循环批量创建Kafka Topic？现有配置执行失败

1. 修正group_vars中的变量定义（YAML缩进问题） #

原变量的缩进不符合YAML规范，会导致Ansible无法正确解析每个topic的配置项。修正后的变量如下：

alltopics:
  - topicname: abc1
    replication: 3
    partitions: 3
  - topicname: xyx
    replication: 3
    partitions: 3
  - topicname: qwe
    replication: 3
    partitions: 3

注意：YAML对缩进严格要求，replication和partitions必须与topicname保持同一层级缩进。

2. 修改Ansible任务实现批量创建 #

原任务硬编码了固定的topic名称和参数，没有遍历变量。修改后的任务通过loop遍历alltopics变量，动态替换每个topic的配置：

- name: 批量创建Kafka Topic
  shell: |
    kafka-topics.sh --create \
      --zookeeper localhost:2181 \
      --replication-factor {{ item.replication }} \
      --partitions {{ item.partitions }} \
      --topic {{ item.topicname }} \
      --if-not-exists
  loop: "{{ alltopics }}"
  register: create_topic_result
  changed_when: "'Created topic' in create_topic_result.stdout"

关键说明： #

• loop: "{{ alltopics }}"：遍历group_vars中定义的所有topic配置，每个循环项用item指代。
• 动态参数替换：用{{ item.replication }}、{{ item.partitions }}、{{ item.topicname }}分别调用每个topic的配置值。
• --if-not-exists参数：避免重复创建已存在的topic时抛出错误，保证任务幂等性（Kafka 2.2及以上版本支持）。
• changed_when设置：只有当命令输出包含Created topic时，才标记任务为"changed"，否则（如topic已存在）标记为"ok"，符合Ansible的状态管理逻辑。

3. 新版本Kafka适配（可选） #

如果使用Kafka 2.8及以上版本，官方推荐使用--bootstrap-server替代--zookeeper（ZooKeeper方式已逐步弃用），修改后的任务如下：

- name: 批量创建Kafka Topic（适配新版本Kafka）
  shell: |
    kafka-topics.sh --create \
      --bootstrap-server localhost:9092 \
      --replication-factor {{ item.replication }} \
      --partitions {{ item.partitions }} \
      --topic {{ item.topicname }} \
      --if-not-exists
  loop: "{{ alltopics }}"
  register: create_topic_result
  changed_when: "'Created topic' in create_topic_result.stdout"

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