- 一起了解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,以后写代码需要用到消息队列时方便多了,随时待命
- 《深入架构 第五篇》 《深入架构 第五篇》
- 《深入架构 第五篇》 《深入架构 第五篇》
- 《读尽源码 第四篇》 《读尽源码 第四篇》
上滑加载中
推荐直播
-
Skill 构建 × 智能创作:基于华为云码道的 AI 内容生产提效方案2026/03/25 周三 19:00-20:00
余伟,华为云软件研发工程师/万邵业(万少),华为云HCDE开发者专家
本次直播带来两大实战:华为云码道 Skill-Creator 手把手搭建专属知识库 Skill;如何用码道提效 OpenClaw 小说文本,打造从大纲到成稿的 AI 原创小说全链路。技术干货 + OPC创作思路,一次讲透!
回顾中 -
码道新技能,AI 新生产力——从自动视频生成到开源项目解析2026/04/08 周三 19:00-21:00
童得力-华为云开发者生态运营总监/何文强-无人机企业AI提效负责人
本次华为云码道 Skill 实战活动,聚焦两大 AI 开发场景:通过实战教学,带你打造 AI 编程自动生成视频 Skill,并实现对 GitHub 热门开源项目的智能知识抽取,手把手掌握 Skill 开发全流程,用 AI 提升研发效率与内容生产力。
回顾中 -
华为云码道:零代码股票智能决策平台全功能实战2026/04/18 周六 10:00-12:00
秦拳德-中软国际教育卓越研究院研究员、华为云金牌讲师、云原生技术专家
利用Tushare接口获取实时行情数据,采用Transformer算法进行时序预测与涨跌分析,并集成DeepSeek API提供智能解读。同时,项目深度结合华为云CodeArts(码道)的代码智能体能力,实现代码一键推送至云端代码仓库,建立起高效、可协作的团队开发新范式。开发者可快速上手,从零打造功能完整的个股筛选、智能分析与风险管控产品。
回顾中
热门标签