У нас есть Spring Boot Service, которая публикует в тему Kafka. Всякий раз, когда тема не существует (скажем, с ошибками), журналы услуг бросают приведенное ниже предупреждение в цикле: < /p>
P> o.k.c.networkclient: [Производитель ClientId = TestService-0] Ответ метаданных от кластера сообщил о восстановлении с Correlation Id 8: {account.messages.valid = inknown_topic_or_partition} < /p>
< /blockquote>
Как только это происходит, проблема не только постоянно регистрирует предупреждение, но и прекращает обработку последующих сообщений. Поймать исключение вокруг линии публикации, кажется, не имеет никакого значения для повторного броска предупреждения.
Подробнее здесь: https://stackoverflow.com/questions/797 ... topic-loop
