fedorm

---
- name: Creating directories for Zookeeper and Kafka
  file:
    name: "{{ item }}"
    state: directory
  loop:
    - "{{ kafka_data_dir }}"
    - "{{ zookeeper_data_dir }}"
    - "{{ zookeeper_log_dir }}"

- name: Creating network for kafka and zookeeper
  docker_network:
    name: kafka

- name: Getting Zookeeper image
  docker_image:
    name: confluentinc/cp-zookeeper
    tag: "{{ zookeeper_image_tag }}"

- name: Getting Kafka image
  docker_image:
    name: confluentinc/cp-kafka
    tag: "{{ kafka_image_tag }}"

- name: Starting Zookeeper
  docker_container:
    name: zookeeper
    image: "confluentinc/cp-zookeeper:{{ zookeeper_image_tag }}"
    state: started
    published_ports:
      - "2181:2181"
    volumes:
      - "{{ zookeeper_data_dir }}:/var/lib/zookeeper/data"
      - "{{ zookeeper_log_dir }}:/var/lib/zookeeper/log"
    env:
      ZOOKEEPER_CLIENT_PORT: 2181
    networks:
      - name: kafka

- name: Waiting for zookeeper to come up
  wait_for:
    port: 2181

- name: Starting Kafka
  docker_container:
    name: kafka
    image: "confluentinc/cp-kafka:{{ kafka_image_tag }}"
    state: started
    published_ports:
      - "9092:9092"
      - "12345:12345"
    volumes:
      - "{{ kafka_data_dir }}:/var/lib/kafka/data"
    env:
      KAFKA_ZOOKEEPER_CONNECT: "zookeeper:2181"
      KAFKA_ADVERTISED_LISTENERS: "PLAINTEXT://{{ ansible_default_ipv4.address }}:9092"
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: "{{ kafka_replication_factor }}"
      KAFKA_LOG_FLUSH_INTERVAL_MS: "{{ kafka_log_flush_interval_ms }}"
      KAFKA_MESSAGE_MAX_BYTES: "{{ kafka_message_max_bytes }}"
      KAFKA_BROKER_ID: "{{ kafka_broker_id }}"
      KAFKA_RESERVED_BROKER_MAX_ID: "{{ kafka_reserved_broker_max_id}}"
      KAFKA_LOG_RETENTION_HOURS: "{{ kafka_log_retention_hours }}"
      KAFKA_JMX_PORT: 12345
      KAFKA_JMX_HOSTNAME: "{{ ansible_default_ipv4.address }}"
    networks:
      - name: kafka

- name: Waiting for Kafka to come up
  wait_for:
    port: 9092