- 本文字数：4223字 预计阅读时间：13分钟 一、RocketMQ简介 RocketMQ是一个高可用、高性能、高可靠的分布式消息队列，相对于kafka更适合处理业务系统之间的消息。 它具有很多特性，例如：发布订阅顺序、事务、定时消息消息堆积、重试，回溯等等 它通过同步刷盘和同步双写等技术手段来实现高可靠，保证如... 本文字数：4223字 预计阅读时间：13分钟 一、RocketMQ简介 RocketMQ是一个高可用、高性能、高可靠的分布式消息队列，相对于kafka更适合处理业务系统之间的消息。 它具有很多特性，例如：发布订阅顺序、事务、定时消息消息堆积、重试，回溯等等 它通过同步刷盘和同步双写等技术手段来实现高可靠，保证如...
- 前言 金三银四即将来临，整理了十道十分经典的消息队列面试题，看完肯定对面试有帮助的，大家一起加油哈~ 什么是消息队列消息队列的应用场景消息队列如何解决消息丢失问题消息队列如何保证消息的顺序性。消息有可能发生重复消费吗？如何幂等处理？如何处理消息队列的消息积压问题消息队列技术选型，Kafka还是RocketMQ，还是Rabbi... 前言 金三银四即将来临，整理了十道十分经典的消息队列面试题，看完肯定对面试有帮助的，大家一起加油哈~ 什么是消息队列消息队列的应用场景消息队列如何解决消息丢失问题消息队列如何保证消息的顺序性。消息有可能发生重复消费吗？如何幂等处理？如何处理消息队列的消息积压问题消息队列技术选型，Kafka还是RocketMQ，还是Rabbi...
- ELK+Kafka+Filebeat日志系统 文章目录 ELK+Kafka+Filebeat日志系统1.环境规划2.部署elasticsearch集群2.1.配置es-1节点2.2.配置es-2... ELK+Kafka+Filebeat日志系统 文章目录 ELK+Kafka+Filebeat日志系统1.环境规划2.部署elasticsearch集群2.1.配置es-1节点2.2.配置es-2...
- 1.问题描述 使用kafka命令删除某个topic之后，查看集群的topic列表时，被删除的tpoic依然存在 # /data/kafka/bin/kafka-topics.sh --delete -... 1.问题描述 使用kafka命令删除某个topic之后，查看集群的topic列表时，被删除的tpoic依然存在 # /data/kafka/bin/kafka-topics.sh --delete -...
- 是什么 Apache Kafka® 是 一个分布式流处理平台 特性 可以让你发布和订阅流式的记录。这一方面与消息队列或者企业消息系统类似。可以储存流式的记录，并且有较好的容错性。可以... 是什么 Apache Kafka® 是 一个分布式流处理平台 特性 可以让你发布和订阅流式的记录。这一方面与消息队列或者企业消息系统类似。可以储存流式的记录，并且有较好的容错性。可以...
- https://blog.csdn.net/kingcat666/article/details/78660535 转载：Java Jedis操作Redis示例（一）——pub/sub模式实现消息队列 转载：消息队列的定义，以及引入消息队列可解决的问题 转载：大型网站架构之分布式消息队列 转载：架构... https://blog.csdn.net/kingcat666/article/details/78660535 转载：Java Jedis操作Redis示例（一）——pub/sub模式实现消息队列 转载：消息队列的定义，以及引入消息队列可解决的问题 转载：大型网站架构之分布式消息队列 转载：架构...
- 消息队列（MQ） 在百度百科中，消息队列（MQ）是这么解释的：“消息队列”是在消息的传输过程中保存消息的容器（可存可取）。 它是分布式系统中重要的组件，使用消息队列主要是为了通过异步处理提高系统性能和削峰和降低系统耦合性。 异步处理：多应用对消息队列中同一消息进行处理，应用间并发处理消息，相比较串行处理，减少处理时间； 应用耦... 消息队列（MQ） 在百度百科中，消息队列（MQ）是这么解释的：“消息队列”是在消息的传输过程中保存消息的容器（可存可取）。 它是分布式系统中重要的组件，使用消息队列主要是为了通过异步处理提高系统性能和削峰和降低系统耦合性。 异步处理：多应用对消息队列中同一消息进行处理，应用间并发处理消息，相比较串行处理，减少处理时间； 应用耦...
- 目录 将消费的kafka数据转换成bean对象 一、将OGG数据转换成bean对象 二、将Canal数据转换成bean对象 三、完整代码 将消费的kafka数据转换成bean对象 一、将OGG数据转换成bean对象 实现步骤： 消费kafka的 logistics Topic数据将消费到的数据转换... 目录 将消费的kafka数据转换成bean对象 一、将OGG数据转换成bean对象 二、将Canal数据转换成bean对象 三、完整代码 将消费的kafka数据转换成bean对象 一、将OGG数据转换成bean对象 实现步骤： 消费kafka的 logistics Topic数据将消费到的数据转换...
- 定义解析kafka数据的Bean对象类 一、定义消费kafka字符串的Bean对象基类 根据数据来源不同可以分为OGG数据和Canal数据，两者之间有相同的属性：table，因此将该属性作为公共属性进行提取，抽象成基类 实现步骤： 在公共模块的java目录下的 parser 包下创建 MessageBean ... 定义解析kafka数据的Bean对象类 一、定义消费kafka字符串的Bean对象基类 根据数据来源不同可以分为OGG数据和Canal数据，两者之间有相同的属性：table，因此将该属性作为公共属性进行提取，抽象成基类 实现步骤： 在公共模块的java目录下的 parser 包下创建 MessageBean ...
- 关注文末公众号，有惊喜福利！ 读这源码有何用？ ReplicaStateMachine是内部组件，一般用户感觉不到存在，但搞懂它，对从根本定位一些数据不一致问题大有裨益。 部署3-Brok... 关注文末公众号，有惊喜福利！ 读这源码有何用？ ReplicaStateMachine是内部组件，一般用户感觉不到存在，但搞懂它，对从根本定位一些数据不一致问题大有裨益。 部署3-Brok...
- Kafka 的消息是保存或缓存在磁盘上的，一般认为在磁盘上读写数据是会降低性能的，因为寻址会比较消耗时间，但是实际上，Kafka 的特性之一就是高吞吐率。 即使是普通的服务器，Kafka 也可以轻松支持每秒百万级的写入请求，超过了大部分的消息中间件，这种特性也使得 Kafka 在日志处理等海量数据场景广泛应用。 针对 Kafka... Kafka 的消息是保存或缓存在磁盘上的，一般认为在磁盘上读写数据是会降低性能的，因为寻址会比较消耗时间，但是实际上，Kafka 的特性之一就是高吞吐率。 即使是普通的服务器，Kafka 也可以轻松支持每秒百万级的写入请求，超过了大部分的消息中间件，这种特性也使得 Kafka 在日志处理等海量数据场景广泛应用。 针对 Kafka...
- 作为一个有丰富经验的微服务系统架构师，经常有人问我，“应该选择RabbitMQ还是Kafka？”。基于某些原因， 许多开发者会把这两种技术当做等价的来看待。的确，在一些案例场景下选择RabbitMQ还是Kafka没什么差别，但是这两种技术在底层实现方面是有许多差异的。 不同的场景需要不同的解决方案，选错一个方案能够严重... 作为一个有丰富经验的微服务系统架构师，经常有人问我，“应该选择RabbitMQ还是Kafka？”。基于某些原因， 许多开发者会把这两种技术当做等价的来看待。的确，在一些案例场景下选择RabbitMQ还是Kafka没什么差别，但是这两种技术在底层实现方面是有许多差异的。 不同的场景需要不同的解决方案，选错一个方案能够严重...
- 起源 在进行架构转型与分库分表之前，我们一直采用非常典型的单体应用架构：主服务是一个 Java WebApp，使用 Nginx 并选择 Session Sticky 分发策略做负载均衡和会话保持；背后是一个 MySQL 主实例，接了若干 Slave 做读写分离。在整个转型开始之前，我们就知道这会是一块难啃的硬骨头：我们要在全线业务飞速... 起源 在进行架构转型与分库分表之前，我们一直采用非常典型的单体应用架构：主服务是一个 Java WebApp，使用 Nginx 并选择 Session Sticky 分发策略做负载均衡和会话保持；背后是一个 MySQL 主实例，接了若干 Slave 做读写分离。在整个转型开始之前，我们就知道这会是一块难啃的硬骨头：我们要在全线业务飞速...
- 技术活，该赏 关注+一键三连（点赞，评论，收藏）再看，养成好习惯 12 RocketMQ使用教程相关系列 目录 RocketMQ的基本概念模型 1 消息模型（Message Model） Ro... 技术活，该赏 关注+一键三连（点赞，评论，收藏）再看，养成好习惯 12 RocketMQ使用教程相关系列 目录 RocketMQ的基本概念模型 1 消息模型（Message Model） Ro...
- 前段时间写了Kafka快速入门系列1-8，但苦于知识点非常繁琐，对于很多初级选手来说并不友好，因此博主又根据... 前段时间写了Kafka快速入门系列1-8，但苦于知识点非常繁琐，对于很多初级选手来说并不友好，因此博主又根据...
上滑加载中
推荐直播
-
华为云码道-玩转OpenClaw，在线养虾2026/03/11 周三 19:00-21:00
刘昱，华为云高级工程师/谈心，华为云技术专家/李海仑，上海圭卓智能科技有限公司CEO
OpenClaw 火爆开发者圈，华为云码道最新推出 Skill ——开发者只需输入一句口令，即可部署一个功能完整的「小龙虾」智能体。直播带你玩转华为云码道，玩转OpenClaw
回顾中 -
华为云码道-AI时代应用开发利器2026/03/18 周三 19:00-20:00
童得力，华为云开发者生态运营总监/姚圣伟，华为云HCDE开发者专家
本次直播由华为专家带你实战应用开发，看华为云码道(CodeArts)代码智能体如何在AI时代让你的创意应用快速落地。更有华为云HCDE开发者专家带你用码道玩转JiuwenClaw，让小艺成为你的AI助理。
回顾中 -
Skill 构建 × 智能创作：基于华为云码道的 AI 内容生产提效方案2026/03/25 周三 19:00-20:00
余伟，华为云软件研发工程师/万邵业（万少），华为云HCDE开发者专家
本次直播带来两大实战：华为云码道 Skill-Creator 手把手搭建专属知识库 Skill；如何用码道提效 OpenClaw 小说文本，打造从大纲到成稿的 AI 原创小说全链路。技术干货 + OPC创作思路，一次讲透！
回顾中
热门标签