humio.kafka

УСТАРЕЛО. Этот репозиторий больше не будет получать обновления. Пожалуйста, рассмотрите возможность использования humio-operator для установки и управления Logscale: https://library.humio.com/falcon-logscale-self-hosted/installation-containers-kubernetes.html.

Установщик Kafka для совместной работы с Humio

Требования

Эта роль должна иметь доступ к установленному Zookeeper.

Переменные роли

Смотрите по умолчанию.

На машинах без доступа к интернету переменную kafka_mirror можно установить на "master", чтобы скопировать архив Kafka из директории файлов мастера.

kafka_mirror: "master"

Осознание стоек

Kafka поддерживает осознание стоек, если вы укажете, в какой стойке находится каждый узел Kafka. Это можно сделать, установив настройку broker.rack в Kafka. Это настраивается в этой роли Ansible через переменную kafka_broker_rack. Чтобы это работало правильно, убедитесь, что каждая стойка или дата-центр определены как группа в вашем инвентаре, и соответствующие машины назначены. Затем вы можете либо установить переменную kafka_broker_rack напрямую в инвентаре, либо создать файл group_vars для каждой из групп стоек/дата-центров, который определяет её должным образом.

По умолчанию всем Kafka назначена одна стойка с именем dc1.

Зависимости

Должен быть установлен Java 9. Рекомендуется использовать роль humio.java.

Пример плейбука

- hosts: servers
  become: true
  vars:
    zookeeper_hosts:
      - zookeeper_id: 1
        ip: "{{ ansible_default_ipv4.address }}"
  roles:
    - role: humio.java
    - role: AnsibleShipyard.ansible-zookeeper
    - role: humio.kafka

Устранение неполадок

Если вам придется прервать выполнение ansible во время шага Установка Kafka из удалённого источника, вы можете столкнуться с ситуацией, когда архив, который загружается и распаковывается, был прерван во время фазы распаковки. Если этот шаг прерван во время загрузки архива (например, таймаут), вы можете просто снова запустить плейбук. Если это произойдет во время фазы распаковки, вам нужно будет вручную очистить директорию /usr/lib/kafka_{{ kafka_scala_version }}-{{ kafka_version }} перед повторным запуском плейбука (на этом этапе проверяется существование этой директории, чтобы пропустить шаг при последующих запусках).

Лицензия

Apache 2.0