humio.kafka

DÉPRÉCIÉ. Ce dépôt ne recevra plus aucune mise à jour. Veuillez envisager d'utiliser humio-operator pour installer et gérer Logscale https://library.humio.com/falcon-logscale-self-hosted/installation-containers-kubernetes.html.

Installer Kafka pour l'exécuter avec Humio

Exigences

Ce rôle doit avoir accès à une installation de Zookeeper.

Variables de rôle

Voir les valeurs par défaut.

Sur les machines sans accès à Internet, la variable kafka_mirror peut être définie sur "master" pour copier le fichier tarball Kafka à partir du répertoire de fichiers du maître.

kafka_mirror: "master"

Connaissance de Rack

Kafka prend en charge la connaissance de rack si vous spécifiez dans quel rack chaque nœud Kafka se trouve. Cela peut être fait en définissant le paramètre broker.rack dans Kafka. Cela est configuré dans ce rôle Ansible via la variable kafka_broker_rack. Pour que cela fonctionne correctement, assurez-vous que chaque rack ou centre de données est défini comme un groupe dans votre inventaire et que les machines appropriées y sont assignées. Vous pouvez ensuite soit définir la variable kafka_broker_rack directement dans l'inventaire, soit créer un fichier group_vars pour chacun des groupes rack/centre de données qui le définit correctement.

Par défaut, tous les Kafka sont assignés à un seul rack nommé dc1.

Dépendances

Java 9 doit être installé. Le rôle humio.java est recommandé.

Exemple de Playbook

- 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

Dépannage

Si vous êtes contraint d'interrompre l'exécution d'ansible lors de l'étape Installer Kafka à distance, vous pourriez rencontrer une situation où le tarball en cours de récupération et d'extraction a été interrompu pendant la phase d'extraction. Si cette étape est interrompue pendant que le tarball est encore en cours de récupération (par exemple, un délai d'attente), vous pouvez simplement réexécuter le playbook. Si cela se produit pendant la phase d'extraction, vous devrez manuellement vider le répertoire /usr/lib/kafka_{{ kafka_scala_version }}-{{ kafka_version }} avant de réexécuter le playbook (cette étape vérifie l'existence de ce répertoire pour sauter l'étape lors de futures exécutions).

Licence

Apache 2.0