RocketMQ 订阅不一致:一次消费者组设计问题排查记录
RocketMQ 订阅不一致:别把注解监听器当成一个 Consumer 简单记录一次 RocketMQ 订阅关系治理。真正的坑不在 Topic 数量,而在于误把 Spring 注解监听器理解成了 Java Client 的“一个 Consumer 多次订阅”。 问题现象 同一个应用里有多个监听器,分别消费不同 T...
继续阅读RocketMQ 订阅不一致:别把注解监听器当成一个 Consumer 简单记录一次 RocketMQ 订阅关系治理。真正的坑不在 Topic 数量,而在于误把 Spring 注解监听器理解成了 Java Client 的“一个 Consumer 多次订阅”。 问题现象 同一个应用里有多个监听器,分别消费不同 T...
继续阅读朋友圈存储从 600G 收口到 3G:位图与事件模型改造记录 简单记录一次朋友圈存储治理:将原本约 600G 的明细模型切换为约 3G 的位图/事件模型,在保持业务结果一致的...
简单记录近期治理 PG 同步到 StarRocks 过程中遇到的各类数据问题及解决方案。 问题一:时间戳转换异常导致同步中断 问题现象 Flink Job 从 RUNNI...
关于 MCP 是什么就不在此赘述,可以看这篇文章:模型上下文协议(MCP) ,目前 Trae 已经支持 MCP,网上还没有什么教程,本文记录下自己安装的过程。 1. 首先安装...
近期和arthas-idea-plugin插件社区沟通,为插件贡献了部分功能,下文为全文转载: 原文链接:《在IDEA中管理和监听arthas应用》 arthas idea ...
在阅读VIVO的博客高性能无锁队列 Disruptor 核心原理分析及其在i主题业务中的应用的时候,了解到 Disruptor 高性能的核心原因: 空间预分配 避免伪共享 ...
此篇文章主要用于讲解使用Spring进行编码时,核心与非核心代码解耦合常用的观察者模式@EventListener的使用方法,以及不常用的@TransactionalEven...
前言 事情的起因还要从 Transaction rolled back because it has been marked as rollback-only] with r...
前言 在MySQL的老版本(MySQL5.7及以前)中, GROUP BY xxx 等同于 GROUP BY xxx ORDER BY xxx,在 GROUP BY 的同时,...
官方文档: Spring Data Neo4j 基于官方文档,基本就能完成基本的接入,Neo4j的版本很乱,如果使用SpringBoot2.+的话,一定要注意Neo4j Se...