upgrade_kafka_connect.yml

---
- name: Kafka Connect Upgrade
  hosts: kafka_connect
  gather_facts: false
  environment: "{{ proxy_env }}"
  serial: 1
  tasks:
    - name: Gather OS Facts
      setup:
        # Only gathers items in list, filters out the rest
        filter: ansible_os_family
        gather_subset:
          - '!all'

    - import_role:
        name: confluent.variables

    - shell: "egrep -i 'ssl.client.auth ?= ?true' {{ kafka_connect.config_file }}"
      register: mtls_check
      failed_when: false

    - name: Set MTLS Variable
      set_fact:
        kafka_connect_ssl_mutual_auth_enabled: "{{ true if mtls_check.rc == 0 else false}}"

    - name: Get Package Facts
      package_facts:
        manager: auto
      when: installation_method == "package"

    - name: Set kafka_connect_current_version variable - Package
      set_fact:
        confluent_server_enabled: "{{ True if ansible_facts.packages['confluent-server'] is defined else False }}"
        kafka_connect_current_version: "{{ ansible_facts.packages['confluent-kafka-connect-replicator'][0]['version'] }}"
      when: installation_method == "package"

    - name: Load override.conf
      slurp:
        src: "{{ kafka_connect.systemd_override }}"
      register: slurped_override
      when: installation_method == "archive"

    - name: Set kafka_connect_current_version variable - Archive
      set_fact:
        kafka_connect_current_version: "{{ (slurped_override.content|b64decode) .split('\n') |
          select('match', '^ExecStart=' + archive_config_base_path + '/confluent-(.*)/bin/connect-distributed ' + kafka_connect.config_file) |
          list | first | regex_search('[0-9]+(.[0-9]+)+') }}"
      when: installation_method == "archive"

    - debug:
        msg: "Current version: {{kafka_connect_current_version}}   Upgrade to version: {{confluent_package_version}}"

    - name: Upgrade Kafka Connect - Package
      include_tasks: tasks/upgrade_component.yml
      vars:
        service_name: "{{ kafka_connect_service_name }}"
        packages: "{{ kafka_connect_packages }}"
        backup_files:
          - "{{ kafka_connect.config_file }}"
          - "{{ kafka_connect.systemd_override }}"
        restore_files:
          - "{{ kafka_connect.config_file }}"
      when:
        - kafka_connect_current_version != confluent_full_package_version
        - kafka_connect_current_version != confluent_package_version
        - installation_method == "package"

    - name: Upgrade Kafka Connect - Archive
      include_tasks: tasks/upgrade_component_archive.yml
      vars:
        service_name: "{{ kafka_connect_service_name }}"
        systemd_file: "{{ kafka_connect.systemd_file }}"
        systemd_override: "{{ kafka_connect.systemd_override }}"
        start_script: "connect-distributed"
        config_file: "{{ kafka_connect.config_file }}"
      when:
        - kafka_connect_current_version != confluent_full_package_version
        - kafka_connect_current_version != confluent_package_version
        - installation_method == "archive"

    - name: Kafka Connect Health Check
      import_role:
        name: confluent.kafka_connect
        tasks_from: health_check.yml
      when: not ansible_check_mode