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 (контроллер) открыты.