У нас есть приложение весенней загрузки, использующее spring-kafka (2.2.5.RELEASE), которое всегда выдает эту ошибку при запуске:
Could not configure topics
org.springframework.kafka.KafkaException: Timed out waiting to get existing
topics; nested exception is java.util.concurrent.TimeoutException
Однако приложение продолжает запускаться:
org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1]
INFO o.s.k.l.KafkaMessageListenerContainer - partitions revoked: []
INFO o.s.k.l.KafkaMessageListenerContainer - partitions assigned: [my-reply-topic-1]
INFO o.s.k.l.KafkaMessageListenerContainer - partitions assigned: [my-request-topic-0]
INFO o.s.b.w.e.tomcat.TomcatWebServer -
Tomcat started on port(s): 8080 (http) with context path ''
На этом этапе приложение взаимодействует с Кафкой, как и ожидалось.
Мы хотели бы сохранить наши журналы в чистоте, поэтому нам хотелось бы понять, почему выбрасывается это исключение.Кроме того, это немного сбивает с толку, потому что, когда мы переходим в другую среду, где не установлено сетевое взаимодействие между приложением и брокером (ами) kafka, мы получаем ту же ошибку, но приложение не работает.То же исключение возникает, когда действительно существует проблема, и когда ее можно игнорировать, утомительно при попытке устранения неполадок с подключением.
Есть ли способ при запуске приложения определить, установлено ли подключение с Kafkaа не просто ждать сообщения о тайм-ауте (которое в любом случае может быть красной сельдью)?