Я работаю над приложением поиска событий, которое управляет заказами. У меня есть потребитель, который представляет собой микропроцессор с пружинной загрузкой, содержащий слушателя, подобного этому:
@KafkaListener(topics = "mytopic", groupId = "mygroup")
public void listenMyTopic(ConsumerRecord<?, String> record) {
log.info("Starting processing ack {}", record.value());
readReturnMessage(record, false);
}
Некоторые (не все) сообщения отправляются в мою тему, но не прослушиваются моим слушателем (я этого не делалнашел их в своих журналах).
Я уверен, что мои сообщения отправляются, потому что я могу использовать их с конечным потребителем.
Есть ли у вас представление о причине этих потерянных сообщений?
Заранее спасибо