Блог

Главная - Вопросы по программированию - Получение ошибки при настройке производителя и потребителя Кафки с помощью Kafkacat

Получение ошибки при настройке производителя и потребителя Кафки с помощью Kafkacat

#apache-kafka #kafka-consumer-api

Вопрос:

с помощью этих команд вы настроили сервер kafka, а затем создали базовую модель производителя-потребителя для отправки приветствия от производителя потребителю.

 brew services start zookeeper
brew services start kafka
kcat -P -b localhost:9092 -t topic1 
kcat -C -b localhost:9092 -t topic1 -o beginning

Получаю эту ошибку при запуске кода потребителя в отдельном терминале.

 ERROR: Topic topic1 error: Broker: Unknown topic or partition

Комментарии:

1. Правильный ли порт кафки? Вы создали topic1 брокера кафки, работающего на localhost:9092 ?

2. Пожалуйста, покажите результаты kcat -L -b localhost:9092

3. там нет выхода из kcat -L -b localhost:9092 . Я могу подключиться к этому порту с помощью telnet

Ответ №1:

На самом деле вы не создавали никаких сообщений, поэтому тема не была создана. kcat -P считывает ввод с консоли и отправляет его Кафке, и в этом случае вы ничего не отправляете.

Например, эти команды:

 echo "My Message" | kcat -P -b localhost:9092 -c 1 -t some-topic
kcat -C -b localhost:9092 -t some-topic

Будет генерировать этот вывод:

 My Message
% Reached end of topic some-topic [0] at offset 1
Метки: