потребитель kafka не читает сообщения из topi c. Я не понимаю проблемы - раньше все работало нормально.
Сообщения обрабатываются 3 раза. В четвертый раз они не обрабатываются. , Если я попытаюсь через 1 час - он снова будет обработан 3 раза и после этого не будет работать.
Почему это происходит?
Ниже приведен код
@Component
@ConditionalOnProperty(value = "XXX", havingValue = "true")
public class EventListener {
@KafkaListener(id = "XX", topics = "#{'${topic'}")
public void consumeMessageEvent(Event messageEvent, ConsumerRecord<String, ?> record) {
}
}