我正在开发一个事件源应用程序来管理订单。我有一个消费者,它是一个spring-boot微服务,包含如下侦听器:
@KafkaListener(topics = "mytopic", groupId = "mygroup")
public void listenMyTopic(ConsumerRecord<?, String> record) {
log.info("Starting processing ack {}", record.value());
readReturnMessage(record, false);
}
有些(不是全部)消息被发送到我的主题,但我的听众没有听(我在日志中没有找到它们)。
我确信我的消息是被发送的,因为我可以用终端消费者来消费它们。
你知道那些信息丢失的原因吗?
先谢谢你
暂无答案!
目前还没有任何答案,快来回答吧!