Почему при отправке сообщений в Кафке, если не правильно написан топик которого не существует то сообщения все равно уходят и нет ошибки?
Почему при отправке сообщений в Кафке, если не правильно написан топик которого не существует то сообщения все равно уходят и нет ошибки?
Ответы (1 шт):
Автор решения: Анастасия
→ Ссылка
Потому что Kafka по умолчанию создает тему, если она не существует.
Чтобы заставить Kafka проверять, существует ли тема, перед тем, как создавать поток, можно настроить соответствующую конфигурацию в настройках Kafka Broker.
За это отвечает конфигурация auto.create.topics.enable, и по умолчанию она = true. Установка значения false должна привести к тому, что если тема не существует, Kafka выдаст ошибку, а не автоматически создаст новую тему.
Дополнительную информацию смотрите в документации.