Test

菜单

Test

所有标签

#HashMap 3 #SpringBoot 1 #Maven 1 #Linux 1 #Mapper 1 #BI 1 #apifox 1 #Java 23 #MyBatis 1 #分布式ID 1 #Clickhouse 2 #连接池 1 #计算机网络 1 #MQ 2 #SQL 1 #ThreadPool 1 #Thread 2 #生产问题 1 #List 2 #Https 2 #MySQL 1 #Dubbo 1 #设计模式 1 #Redis 2 #通信安全 2 #日常问题 1 #Zookeeper 1 #Pulsar 1 #大数据 3 #回溯 1
#MQ#Pulsar

记一次MQ消费失败引发的一系列问题

背景 使用了腾讯云封装的 Pulsar 作为云消息队列，消费中有大致就是一个异步 MQ 日志落库的逻辑。我们日志库使用的 ClickHouse，那天 CK 出现了一段时间的连接异常导致 MQ 消费一直消费异常，进而 Consumer 没再接收到任何消息，但是我本地主动发起了一笔请求，消息成功消费日志

Administrator Administrator 发布于 2026-06-12
#MQ

CMQ使用相关总结

基础用法 消息确认模式（ AcknowledgeMode ） NONE：自动确认，一旦消息到达了消费者端即视为该消息无误了。该情况可能会出现若消费者端出现了异常，而此时又自动确认了，因此容易导致消息删除，容易造成消息丢失。 AUTO：根据情况确认 执行无异常将自动确认 执行抛出 AmqpReject

Administrator Administrator 发布于 2026-06-12