Kafka

C’est un système de file d’attente distribuée.

Commande de gestion des topics

# Lister les topics
./kafka-topics.sh --zookeeper 10.8.8.20:2181 --list
# Obtenir les infos d'un topic
./kafka-topics.sh --zookeeper 10.8.8.20:2181 --topic test --describe
# Créer un topic
./kafka-topics.sh --zookeeper 10.8.8.20:2181 --create --topic logstash --partitions 32 --replication-factor 2

Outils de debug

Pour écouter le topic “logstash” : kafkacat -b 10.8.8.37 -t logstash