- 技术活，该赏关注+一键三连（点赞，评论，收藏）再看，养成好习惯 RocketMQ使用教程相关系列 目录 目录 第一节：介绍 顺序消息含义介绍 原理解析 第二节：顺序消息-生产者和消息者步骤说明 顺序消息生产者代码实现步骤 顺序消息消费者代码实现步骤 第三节：顺序消息生产者 效果： 第四节：顺序消息消费者 效果：... 技术活，该赏关注+一键三连（点赞，评论，收藏）再看，养成好习惯 RocketMQ使用教程相关系列 目录 目录 第一节：介绍 顺序消息含义介绍 原理解析 第二节：顺序消息-生产者和消息者步骤说明 顺序消息生产者代码实现步骤 顺序消息消费者代码实现步骤 第三节：顺序消息生产者 效果： 第四节：顺序消息消费者 效果：...
- 首先先看下任务计划书 ，大概了解了下这个任务的主要工作是通过flink读取Kafka写入GaussDB并且可以写入数据的验证工作。主要是需要花时间熟悉kafka和flink的架构、环境搭建、扩展新功能和开发简单的界面展示效果。下面介绍下适配过程中的一些关键步骤。开发过程首先参考任务计划书给的参考资料： https://kafka.apache.org/和 https://flink.apac... 首先先看下任务计划书 ，大概了解了下这个任务的主要工作是通过flink读取Kafka写入GaussDB并且可以写入数据的验证工作。主要是需要花时间熟悉kafka和flink的架构、环境搭建、扩展新功能和开发简单的界面展示效果。下面介绍下适配过程中的一些关键步骤。开发过程首先参考任务计划书给的参考资料： https://kafka.apache.org/和 https://flink.apac...
- Kafka其实是一款基于发布与订阅模式的消息系统，如果按常理来设计，大家是不是把消息发送者的消息直接发送给消息消费者？但Kafka并不是这么设计的，Kafka消息的生产者会对消息进行分类，再发送给中间的消息服务系统，而消息消费者通过订阅某分类的消息去接受特定类型的消息。 Kafka其实是一款基于发布与订阅模式的消息系统，如果按常理来设计，大家是不是把消息发送者的消息直接发送给消息消费者？但Kafka并不是这么设计的，Kafka消息的生产者会对消息进行分类，再发送给中间的消息服务系统，而消息消费者通过订阅某分类的消息去接受特定类型的消息。
- 一起了解Kafka如何作为数据流转的桥梁。 一起了解Kafka如何作为数据流转的桥梁。
- 本文总结了消息队列的12个核心原理，涵盖消息顺序性、ACK机制、持久化及高可用性等内容。关注【mikechen的互联网架构】，10年+BAT架构经验倾囊相授。 本文总结了消息队列的12个核心原理，涵盖消息顺序性、ACK机制、持久化及高可用性等内容。关注【mikechen的互联网架构】，10年+BAT架构经验倾囊相授。
- 消息队列概述前言这是我在这个网站整理的笔记,有错误的地方请指出，关注我，接下来还会持续更新。作者：神的孩子都在歌唱消息队列（Message Queue）是一种常见的异步通信机制，用于在不同的应用程序之间传递消息。在消息队列中，消息的发送者将消息发送到队列中，而消息的接收者则从队列中读取消息。消息队列可以实现解耦合、异步通信、缓冲、削峰填谷等功能，是大规模分布式系统中常用的通信方式之一。一. ... 消息队列概述前言这是我在这个网站整理的笔记,有错误的地方请指出，关注我，接下来还会持续更新。作者：神的孩子都在歌唱消息队列（Message Queue）是一种常见的异步通信机制，用于在不同的应用程序之间传递消息。在消息队列中，消息的发送者将消息发送到队列中，而消息的接收者则从队列中读取消息。消息队列可以实现解耦合、异步通信、缓冲、削峰填谷等功能，是大规模分布式系统中常用的通信方式之一。一. ...
- 01架构概览Zookeeper 提供了配置服务、分布式同步、命名服务、Leader 选举和集群管理等功能，在大数据时代的开始很多开源产品都依赖 Zookeeper 来构建，Apache Kafka 也不例外。但是随着 Kafka 功能的演进和应用的场景越来越多：基于 Zookeeper 的协作模式，使得 Kafka 的集群一致性维护越来越复杂；受到 Zookeeper 性能的限制，使得 Ka... 01架构概览Zookeeper 提供了配置服务、分布式同步、命名服务、Leader 选举和集群管理等功能，在大数据时代的开始很多开源产品都依赖 Zookeeper 来构建，Apache Kafka 也不例外。但是随着 Kafka 功能的演进和应用的场景越来越多：基于 Zookeeper 的协作模式，使得 Kafka 的集群一致性维护越来越复杂；受到 Zookeeper 性能的限制，使得 Ka...
- 手拉手springboot整合kafka生产者发送消息 手拉手springboot整合kafka生产者发送消息
- 随着互联网的发展，越来越多的公司摒弃了Hibernate，而选择拥抱了MyBatis。而且，很多大厂在面试的时候喜欢问MyBatis底层的原理和源码实现。总之，MyBatis几乎成为了Java开发人员必须深入掌握的框架技术，今天，我们就一起来深入分析MyBatis源码。文章有点长，建议先收藏后慢慢研究。整体三万字左右，全程高能，小伙伴们可慢慢研究。 随着互联网的发展，越来越多的公司摒弃了Hibernate，而选择拥抱了MyBatis。而且，很多大厂在面试的时候喜欢问MyBatis底层的原理和源码实现。总之，MyBatis几乎成为了Java开发人员必须深入掌握的框架技术，今天，我们就一起来深入分析MyBatis源码。文章有点长，建议先收藏后慢慢研究。整体三万字左右，全程高能，小伙伴们可慢慢研究。
- 在当今的数字化世界中，实时数据已经成为企业运营的关键因素。其中，温度实时数据的重要性不言而喻，特别是在物流、制造业、农业等领域。华为云分布式消息服务Kafka版作为一种高效、可靠的消息队列服务，可以帮助企业实现对温度实时数据的实时采集、传输和处理。本文将详细介绍如何使用华为云分布式消息服务Kafka版对接温度实时数据。一、华为云分布式消息服务Kafka版介绍华为云分布式消息服务Kafka版是... 在当今的数字化世界中，实时数据已经成为企业运营的关键因素。其中，温度实时数据的重要性不言而喻，特别是在物流、制造业、农业等领域。华为云分布式消息服务Kafka版作为一种高效、可靠的消息队列服务，可以帮助企业实现对温度实时数据的实时采集、传输和处理。本文将详细介绍如何使用华为云分布式消息服务Kafka版对接温度实时数据。一、华为云分布式消息服务Kafka版介绍华为云分布式消息服务Kafka版是...
- 问题描述 部分消费组无法通过broker(new-consumer)正常消费数据,更改消费组名后恢复正常。 group名(可能涉及业务信息，group名非真实名): group1-打马赛克 group2-打马赛克 kafka版本: 0.9.0.1 问题描述 部分消费组无法通过broker(new-consumer)正常消费数据,更改消费组名后恢复正常。 group名(可能涉及业务信息，group名非真实名): group1-打马赛克 group2-打马赛克 kafka版本: 0.9.0.1
- 小组同学在使用kafka官方工具kafka-consumer-groups.sh批量导集群消费组详情时,发现某一个集群基于broker的某些消费组会出现异常，主要表现： 结果不全: 只有部分分区的信息 进程会阻塞: 不会像导他消费组时那样，执行完自动退出 小组同学在使用kafka官方工具kafka-consumer-groups.sh批量导集群消费组详情时,发现某一个集群基于broker的某些消费组会出现异常，主要表现： 结果不全: 只有部分分区的信息 进程会阻塞: 不会像导他消费组时那样，执行完自动退出
- 👍希望您能有所收获 一.初识MQ (1) 引入微服务间通讯有同步和异步两种方式：同步通讯：就像打电话，可以立即得到响应，但是你却不能跟多个人同时通话。异步通讯：就像发消息，可以同时与多个人发送并接收消息，但是往往响应会有延迟。 (2) 同步通讯我们之前学习的Feign远程调用就属于同步方式，虽然调用可以实时得到结果，但存在下面的问题：同步调用的优点：时效性较强，可以立即得到结果同步调用的缺... 👍希望您能有所收获 一.初识MQ (1) 引入微服务间通讯有同步和异步两种方式：同步通讯：就像打电话，可以立即得到响应，但是你却不能跟多个人同时通话。异步通讯：就像发消息，可以同时与多个人发送并接收消息，但是往往响应会有延迟。 (2) 同步通讯我们之前学习的Feign远程调用就属于同步方式，虽然调用可以实时得到结果，但存在下面的问题：同步调用的优点：时效性较强，可以立即得到结果同步调用的缺...
- 本文通过实战展示了如何在K8S环境部署kafka集群，并且K8S环境外部也能使用此服务 本文通过实战展示了如何在K8S环境部署kafka集群，并且K8S环境外部也能使用此服务
- 家用的群晖DS218+从不关机，装上了kafka，以后写代码需要用到消息队列时方便多了，随时待命 家用的群晖DS218+从不关机，装上了kafka，以后写代码需要用到消息队列时方便多了，随时待命
上滑加载中
推荐直播
0.3333333333333333
-
空中宣讲会 2025年华为软件精英挑战赛2025/03/10 周一 18:00-19:00
宸睿 华为云存储技术专家、ACM-ICPC WorldFinal经验 晖哥
2025华为软挑赛空中宣讲会重磅来袭！完整赛程首曝+命题天团硬核拆题+三轮幸运抽奖赢参赛助力礼包，与全国优秀高校开发者同台竞技，直通顶尖赛事起跑线！
即将直播 -
CloudPond上的DeepSeek2025/03/07 周五 16:30-17:30
George-华为云CloudPond解决方案经理
比一体机能力更丰满；比公有云距离更亲近；比自己搭建更轻松简单；解读在CloudPond 上部署DeepSeek，选型、方案以及部署维护的细节。
即将直播 -
空中宣讲会 2025年华为软件精英挑战赛
2025/03/10 周一 18:00-19:00
宸睿 华为云存储技术专家、ACM-ICPC WorldFinal经验 晖哥
2025华为软挑赛空中宣讲会重磅来袭！完整赛程首曝+命题天团硬核拆题+三轮幸运抽奖赢参赛助力礼包，与全国优秀高校开发者同台竞技，直通顶尖赛事起跑线！
即将直播 -
CloudPond上的DeepSeek
2025/03/07 周五 16:30-17:30
George-华为云CloudPond解决方案经理
比一体机能力更丰满；比公有云距离更亲近；比自己搭建更轻松简单；解读在CloudPond 上部署DeepSeek，选型、方案以及部署维护的细节。
即将直播
热门标签
