Важные файлы и директории
- Основной каталог установки 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 - Системный журнал:
sudo journalctl -u kafka -f - Убедитесь, что порты
9092(брокер) и9093(контроллер) открыты.