kafkalistener丢失消息

tjvv9vkg  于 2021-06-04  发布在  Kafka
关注(0)|答案(0)|浏览(332)

我正在开发一个事件源应用程序来管理订单。我有一个消费者,它是一个spring-boot微服务,包含如下侦听器:

@KafkaListener(topics = "mytopic", groupId = "mygroup")
    public void listenMyTopic(ConsumerRecord<?, String> record) {
        log.info("Starting processing ack {}", record.value());
        readReturnMessage(record, false);
    }

有些(不是全部)消息被发送到我的主题,但我的听众没有听(我在日志中没有找到它们)。
我确信我的消息是被发送的,因为我可以用终端消费者来消费它们。
你知道那些信息丢失的原因吗?
先谢谢你

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题