- 技术活，该赏关注+一键三连（点赞，评论，收藏）再看，养成好习惯 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，以后写代码需要用到消息队列时方便多了，随时待命
上滑加载中
推荐直播
-
华为云 x DeepSeek：AI驱动云上应用创新2025/02/26 周三 16:00-18:00
华为云 AI专家大咖团
在 AI 技术飞速发展之际，DeepSeek 备受关注。它凭借哪些技术与理念脱颖而出？华为云与 DeepSeek 合作，将如何重塑产品与应用模式，助力企业数字化转型？在华为开发者空间，怎样高效部署 DeepSeek，搭建专属服务器？基于华为云平台，又该如何挖掘 DeepSeek 潜力，实现智能化升级？本期直播围绕DeepSeek在云上的应用案例，与DTSE布道师们一起探讨如何利用AI 驱动云上应用创新。
回顾中 -
智能观测进化论系列沙龙（第一期）2025/02/28 周五 14:00-16:30
华为及外部讲师团
本期直播就智能化可观测技术的融合与创新、落地与实践、瓶颈与未来等业界关心的话题进行深入探讨。
回顾中 -
聚焦Deepseek，洞察开发者生态发展2025/02/28 周五 19:00-20:30
蒋涛 csdn创始人
深入剖析Deepseek爆发后，中国开发者生态潜藏的巨大发展潜能与未来走向，精准提炼出可供大家把握的时代机遇，干货满满，不容错过。
回顾中
热门标签