Apache Kafka

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

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

Кафка Сервіс

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 припинити читання.

Події можуть використовуватися кількома клієнтами кілька разів.

Журнали та усунення несправностей

• Журнали Кафки: /opt/kafka/logs
• Журнал Systemd: sudo journalctl -u kafka -f
• Забезпечити порти 9092 (брокер) і 9093 (контролер) відкриті.