Topi c (s) [xxx] присутствует / отсутствует и отсутствуетTopicsFatal имеет значение true

Question

При попытке интегрировать kafka с весенней загрузкой я получаю следующее исключение:

java.lang.IllegalStateException: Topic(s) [pushEvent] is/are not present and missingTopicsFatal is true

На основании этого потока Я пытался установить свойство spring.kafka.listener.missing-topics-fatal до false. Поскольку у меня есть приложение jHipster, я добавил следующую конфигурацию в мой application.yml:

spring:
  kafka:
    listener:
      missing-topics-fatal: false

Каким-то образом вышеуказанная конфигурация не дала эффекта, и я все еще получаю вышеупомянутое исключение.

Я что-то упустил в конфиге yaml? Нужно ли делать что-то дополнительное?

Answer 1

Похоже, что topi c вы пытаетесь создать сообщение не создано. Вы можете решить эту проблему с помощью одной из следующих опций:

• Создание топи c вручную:

  bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test

• Включение автоматического создания топи c с настройкой auto.create.topics.enable в true в конфигах брокера. (файл config / server.properties на стороне брокера)

auto.create.topics.enable: Включить автоматическое создание топи c на сервер