humio.kafka

DEPRECJA. To repozytorium nie będzie już aktualizowane. Proszę rozważyć użycie humio-operatora do instalacji i zarządzania Logscale, https://library.humio.com/falcon-logscale-self-hosted/installation-containers-kubernetes.html.

Instalator Kafka do użycia z Humio

Wymagania

Ta rola musi mieć dostęp do zainstalowanego Zookeepera.

Zmienne roli

Sprawdź domyślne ustawienia.

Na maszynach bez dostępu do internetu, zmienna kafka_mirror może być ustawiona na "master", aby skopiować plik tarball Kafka z katalogu plików głównego.

kafka_mirror: "master"

Świadomość Racków

Kafka obsługuje świadomość racków, jeśli określisz, w jakim racku znajduje się każdy węzeł Kafka. Można to zrobić, ustawiając opcję broker.rack w Kafka. Jest to skonfigurowane w tej roli Ansible za pomocą zmiennej kafka_broker_rack. Aby to działało poprawnie, upewnij się, że każdy rack lub centrum danych jest zdefiniowane jako grupa w twoim inwentarzu, a odpowiednie maszyny są przypisane. Możesz wtedy albo ustawić zmienną kafka_broker_rack bezpośrednio w inwentarzu, albo utworzyć plik group_vars dla każdej grupy racku/centrum danych, który ją odpowiednio definiuje.

Domyślnie wszystkie Kafki są przypisane do jednego racku o nazwie dc1.

Zależności

Java 9 musi być zainstalowane. Rekomendowana jest rola humio.java.

Przykład Playbooka

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

Rozwiązywanie problemów

Jeśli musisz przerwać działanie Ansible w trakcie kroku Instalowanie Kafka zdalnie, możesz napotkać sytuację, w której plik tarball, który jest pobierany i rozpakowywany, został przerwany podczas etapu rozpakowywania. Jeśli ten etap jest przerywany w trakcie pobierania pliku tarball (np. z powodu limitu czasu), możesz po prostu ponownie uruchomić playbook. Jeśli wystąpi to podczas fazy rozpakowywania, będziesz musiał ręcznie wyczyścić katalog /usr/lib/kafka_{{ kafka_scala_version }}-{{ kafka_version }} przed ponownym uruchomieniem playbooka (ten etap sprawdza istnienie tego katalogu, aby pominąć krok w przyszłych uruchomieniach).

Licencja

Apache 2.0