Apache Kafka

Важливі файли та директорії

• Головна директорія встановлення Kafka: /opt/kafka
• Файл конфігурації брокера Kafka: /opt/kafka/config/server.properties
• Директорія журналів Kafka (журнали брокера, збережені події): /opt/kafka/logs
• Виконувані файли та CLI-інструменти Kafka (kafka-topics.sh, kafka-console-producer.sh, тощо): /opt/kafka/bin
• Systemd-юніт для керування Kafka: /etc/systemd/system/kafka.service

Сервіс Kafka

sudo systemctl restart kafka
sudo systemctl enable kafka
sudo systemctl status kafka

Створити тему

/opt/kafka/bin/kafka-topics.sh --create --topic quickstart-events --bootstrap-server localhost:9092

Перевірити деталі топіку:

/opt/kafka/bin/kafka-topics.sh --describe --topic quickstart-events --bootstrap-server localhost:9092

Публікація подій (повідомлень)

/opt/kafka/bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

Вводьте по одній події на рядок.

Натисніть Ctrl+C вийти.

Отримувати подій

/opt/kafka/bin/kafka-console-consumer.sh --topic quickstart-events --from-beginning --bootstrap-server localhost:9092

Натисніть Ctrl+C припинити читання.

Одні й ті самі події можуть зчитуватися кількома клієнтами незалежно один від одного.

Журнали та усунення неполадок

• Журнали Kafka: /opt/kafka/logs
• Журнал systemd: sudo journalctl -u kafka -f
• Переконайтеся в портах 9092 (брокер) та 9093 (controller) відкриті.