Пример простой загрузки Kafka Spring не работает

Question

Я начал исследовать Кафку пару дней go. Я прочитал много статей в сети, а потом просто захотел попробовать это вручную. Вот я и нашел эту статью https://www.confluent.io/blog/apache-kafka-spring-boot-application/

Но у меня она не работает. Весенняя загрузка началась, но у меня в журнале есть такие сообщения:

В чем может быть причина этих сообщений и как я могу это исправить?

Когда я выполните этот запрос: curl -X POST -F 'message = test' http://localhost: 9000 / kafka / publi sh

Я вижу, что производитель отправляет сообщение, но Потребитель по какой-то причине не получает.

И еще один вопрос. В статье они отправляют сообщение «пользователям» topi c, но оно нигде в коде не объявляется. Как это возможно?

Answer 1

Вы должны подтвердить запуск kafka и zookeeper, в этой статье я этого не вижу. Простой способ запустить сервер kafka - это docker -compose, например https://github.com/wurstmeister/kafka-docker/blob/master/docker-compose.yml. После этого необходимо проверить порты для подключения в приложении Spring Boot и на сервере kafka.