У меня есть приложение, которое использует SpringBoot 2.10.0. Release и kafka в версии 2.10.0. Приложение имеет простого производителя и потребителя: отправитель работает с KafkaTemplate, а потребитель - с KafkaListener.
Я пытаюсь добиться того, чтобы у меня была возможность запускать приложение SpringBoot, даже если KafkaServer не запущен.
В настоящее время без запущенного KafkaBroker приложение не может быть запущено с этим сообщением об ошибке:
org.springframework.context.ApplicationContextException:
Failed to start bean 'org.springframework.kafka.config.internalKafkaListenerEndpointRegistry';
nested exception is org.apache.kafka.common.errors.TimeoutException
Есть ли способ достичь этого, и если да, может кто-нибудь дать мне подсказку или ключевое слово, как это сделать?