- docker安装命令，其中172.16.11.111是宿主机ip，14818是宿主机端口，对应容器端口9092：docker run -d \ --name kafka \ -p 14818:9092 \ -p 9093:9093 \ -v /tmp/kraft-combined-logs:/tmp/kraft-combined-logs \ -e TZ=Asia/Shangha... docker安装命令，其中172.16.11.111是宿主机ip，14818是宿主机端口，对应容器端口9092：docker run -d \ --name kafka \ -p 14818:9092 \ -p 9093:9093 \ -v /tmp/kraft-combined-logs:/tmp/kraft-combined-logs \ -e TZ=Asia/Shangha...
- 开篇语哈喽，各位小伙伴们，你们好呀，我是喵手。运营社区：C站/掘金/腾讯云/阿里云/华为云/51CTO；欢迎大家常来逛逛 今天我要给大家分享一些自己日常学习到的一些知识点，并以文字的形式跟大家一起交流，互相学习，一个人虽可以走的更快，但一群人可以走的更远。 我是一名后端开发爱好者，工作日常接触到最多的就是Java语言啦，所以我都尽量抽业余时间把自己所学到所会的，通过文章的形式进行输出，... 开篇语哈喽，各位小伙伴们，你们好呀，我是喵手。运营社区：C站/掘金/腾讯云/阿里云/华为云/51CTO；欢迎大家常来逛逛 今天我要给大家分享一些自己日常学习到的一些知识点，并以文字的形式跟大家一起交流，互相学习，一个人虽可以走的更快，但一群人可以走的更远。 我是一名后端开发爱好者，工作日常接触到最多的就是Java语言啦，所以我都尽量抽业余时间把自己所学到所会的，通过文章的形式进行输出，...
- 🏆本文收录于「滚雪球学SpringBoot」专栏(全网一个名)，手把手带你零基础入门Spring Boot，从入门到就业，助你早日登顶实现财富自由🚀；同时，欢迎大家关注&&收藏&&订阅！持续更新中，up！up！up！！环境说明：Windows 10 + IntelliJ IDEA 2021.3.2 + Jdk 1.8 前言随着系统复杂度的提升，异步通信和解耦变得越来越重要。Kafka 作... 🏆本文收录于「滚雪球学SpringBoot」专栏(全网一个名)，手把手带你零基础入门Spring Boot，从入门到就业，助你早日登顶实现财富自由🚀；同时，欢迎大家关注&&收藏&&订阅！持续更新中，up！up！up！！环境说明：Windows 10 + IntelliJ IDEA 2021.3.2 + Jdk 1.8 前言随着系统复杂度的提升，异步通信和解耦变得越来越重要。Kafka 作...
- 🏆本文收录于「滚雪球学SpringBoot」专栏(全网一个名)，手把手带你零基础入门Spring Boot，从入门到就业，助你早日登顶实现财富自由🚀；同时，欢迎大家关注&&收藏&&订阅！持续更新中，up！up！up！！环境说明：Windows 10 + IntelliJ IDEA 2021.3.2 + Jdk 1.8 前言在现代分布式系统中，消息队列作为一种强有力的解耦工具，帮助开发者在... 🏆本文收录于「滚雪球学SpringBoot」专栏(全网一个名)，手把手带你零基础入门Spring Boot，从入门到就业，助你早日登顶实现财富自由🚀；同时，欢迎大家关注&&收藏&&订阅！持续更新中，up！up！up！！环境说明：Windows 10 + IntelliJ IDEA 2021.3.2 + Jdk 1.8 前言在现代分布式系统中，消息队列作为一种强有力的解耦工具，帮助开发者在...
- 1、为什么要使用MQ1）解耦：A 系统发送数据到 BCD 三个系统，通过接口调用发送。如果 E 系统也要这个数据呢？那如果 C 系统现在不需要了呢？A 系统负责人几乎崩溃…A 系统跟其它各种乱七八糟的系统严重耦合，A 系统产生一条比较关键的数据，很多系统都需要 A 系统将这个数据发送过来。如果使用MQ，A 系统产生一条数据，发送到 MQ 里面去，哪个系统需要数据自己去 MQ 里面消费。如... 1、为什么要使用MQ1）解耦：A 系统发送数据到 BCD 三个系统，通过接口调用发送。如果 E 系统也要这个数据呢？那如果 C 系统现在不需要了呢？A 系统负责人几乎崩溃…A 系统跟其它各种乱七八糟的系统严重耦合，A 系统产生一条比较关键的数据，很多系统都需要 A 系统将这个数据发送过来。如果使用MQ，A 系统产生一条数据，发送到 MQ 里面去，哪个系统需要数据自己去 MQ 里面消费。如...
- 摘要： Apache Kafka是一款高性能分布式消息队列，采用主题（topic）、分区（partition）和分段（segment）机制实现海量数据吞吐。其核心设计包括：批量日志存储（压缩消息至4KB批次）、稀疏索引（偏移量和时间戳索引）加速查询，以及基于顺序I/O的Page Cache异步刷盘策略。日志支持两种清理策略——按时间/大小删除或按Key合并（保留最新值）。 摘要： Apache Kafka是一款高性能分布式消息队列，采用主题（topic）、分区（partition）和分段（segment）机制实现海量数据吞吐。其核心设计包括：批量日志存储（压缩消息至4KB批次）、稀疏索引（偏移量和时间戳索引）加速查询，以及基于顺序I/O的Page Cache异步刷盘策略。日志支持两种清理策略——按时间/大小删除或按Key合并（保留最新值）。
- 验证kafka集群2AZ部署可行性 验证kafka集群2AZ部署可行性
- 不是你消息太多，而是你不会排队：openEuler 的消息队列实战手记 不是你消息太多，而是你不会排队：openEuler 的消息队列实战手记
- Spring Boot + Kafka 亿级日志收集系统：零丢失传输与实时分析架构关键词：Spring Boot、Kafka、亿级日志、零丢失、实时分析、Exactly-Once、背压、熔断、可观测性 一、总体设计思路维度目标关键技术吞吐单集群 300 MB/s → 1 GB/s异步批量、压缩、零拷贝可靠性零消息丢失acks=all、幂等 Producer、事务、ISR实时性90% 日志 ... Spring Boot + Kafka 亿级日志收集系统：零丢失传输与实时分析架构关键词：Spring Boot、Kafka、亿级日志、零丢失、实时分析、Exactly-Once、背压、熔断、可观测性 一、总体设计思路维度目标关键技术吞吐单集群 300 MB/s → 1 GB/s异步批量、压缩、零拷贝可靠性零消息丢失acks=all、幂等 Producer、事务、ISR实时性90% 日志 ...
- 开篇语哈喽，各位小伙伴们，你们好呀，我是喵手。运营社区：C站/掘金/腾讯云/阿里云/华为云/51CTO；欢迎大家常来逛逛 今天我要给大家分享一些自己日常学习到的一些知识点，并以文字的形式跟大家一起交流，互相学习，一个人虽可以走的更快，但一群人可以走的更远。 我是一名后端开发爱好者，工作日常接触到最多的就是Java语言啦，所以我都尽量抽业余时间把自己所学到所会的，通过文章的形式进行输出，... 开篇语哈喽，各位小伙伴们，你们好呀，我是喵手。运营社区：C站/掘金/腾讯云/阿里云/华为云/51CTO；欢迎大家常来逛逛 今天我要给大家分享一些自己日常学习到的一些知识点，并以文字的形式跟大家一起交流，互相学习，一个人虽可以走的更快，但一群人可以走的更远。 我是一名后端开发爱好者，工作日常接触到最多的就是Java语言啦，所以我都尽量抽业余时间把自己所学到所会的，通过文章的形式进行输出，...
- 🏆本文收录于「滚雪球学SpringBoot」专栏(全网一个名)，手把手带你零基础入门Spring Boot，从入门到就业，助你早日登顶实现财富自由🚀；同时，欢迎大家关注&&收藏&&订阅！持续更新中，up！up！up！！环境说明：Windows 10 + IntelliJ IDEA 2021.3.2 + Jdk 1.8 🚀 前言在现代分布式系统中，事件驱动架构（EDA）和消息流处理已成为... 🏆本文收录于「滚雪球学SpringBoot」专栏(全网一个名)，手把手带你零基础入门Spring Boot，从入门到就业，助你早日登顶实现财富自由🚀；同时，欢迎大家关注&&收藏&&订阅！持续更新中，up！up！up！！环境说明：Windows 10 + IntelliJ IDEA 2021.3.2 + Jdk 1.8 🚀 前言在现代分布式系统中，事件驱动架构（EDA）和消息流处理已成为...
- 在当今互联网应用中，高并发场景如电商秒杀、社交平台热点事件或金融交易系统，常常面临突如其来的流量洪峰。这些峰值可能导致后端服务瞬间过载，引发系统崩溃、响应延迟甚至数据丢失。想象一下，双十一购物节时，数百万用户同时下单，如果数据库直接处理所有写入请求，服务器可能像堵车的高速公路一样瘫痪。那么，如何优雅地应对这种挑战？答案就是引入消息队列（Message Queue）作为缓冲层，实现流量削峰（T... 在当今互联网应用中，高并发场景如电商秒杀、社交平台热点事件或金融交易系统，常常面临突如其来的流量洪峰。这些峰值可能导致后端服务瞬间过载，引发系统崩溃、响应延迟甚至数据丢失。想象一下，双十一购物节时，数百万用户同时下单，如果数据库直接处理所有写入请求，服务器可能像堵车的高速公路一样瘫痪。那么，如何优雅地应对这种挑战？答案就是引入消息队列（Message Queue）作为缓冲层，实现流量削峰（T...
- Java消息队列应用：Kafka、RabbitMQ选择与优化在Java应用领域，消息队列是实现异步通信、应用解耦、流量削峰等重要功能的关键组件。Kafka和RabbitMQ作为两种主流的消息队列技术，各有特点和适用场景。本文将深入探讨Kafka和RabbitMQ在Java中的应用，并提供优化建议，帮助开发者根据业务需求做出合理选择。 一、Kafka和RabbitMQ的基本概念与架构 （一）... Java消息队列应用：Kafka、RabbitMQ选择与优化在Java应用领域，消息队列是实现异步通信、应用解耦、流量削峰等重要功能的关键组件。Kafka和RabbitMQ作为两种主流的消息队列技术，各有特点和适用场景。本文将深入探讨Kafka和RabbitMQ在Java中的应用，并提供优化建议，帮助开发者根据业务需求做出合理选择。 一、Kafka和RabbitMQ的基本概念与架构 （一）...
- linux命令使用消费kafka的生产者、消费者 linux命令使用消费kafka的生产者、消费者
- 本文深入探讨了消息中间件的核心功能实现与高并发、高可用设计。在生产者设计中，涵盖消息构造、序列化、路由策略及可靠性保障（如ACK机制）。消费者部分分析了拉取/推送模式、分区分配与消息确认机制。同时，Broker作为核心组件，负责消息路由、存储和投递，并通过索引技术实现快速检索。 高并发设计方面，重点讨论了文件存储（顺序写入、分段存储）、日志结构存储及负载均衡策略（如哈希分区、轮询分区）。为确保高可 本文深入探讨了消息中间件的核心功能实现与高并发、高可用设计。在生产者设计中，涵盖消息构造、序列化、路由策略及可靠性保障（如ACK机制）。消费者部分分析了拉取/推送模式、分区分配与消息确认机制。同时，Broker作为核心组件，负责消息路由、存储和投递，并通过索引技术实现快速检索。 高并发设计方面，重点讨论了文件存储（顺序写入、分段存储）、日志结构存储及负载均衡策略（如哈希分区、轮询分区）。为确保高可
上滑加载中
推荐直播
-
昇腾AI算法挑战赛-核心算子如何优化？专家带你深度解析2025/11/17 周一 16:00-17:00
王老师 华为算子专家
昇腾AI算法挑战赛进阶赛战鼓催征！本期直播间，我们特邀华为算子专家王老师，为你深度剖析Matmul、wholereducesum等核心算子的底层原理与优化技巧，直击赛题核心。想提升代码效率、冲击更高排名？锁定直播，带你破局！
回顾中 -
AI编码实干派，“码”力全开2026/02/26 周四 15:00-16:30
谈宗玮/于邦旭/丁俊卿/陈云亮/王一男
【中国，深圳，2026年2月26日】，以“AI编码实干派，码力全开”为主题的华为云码道（CodeArts）代码智能体新春发布会在线上成功召开。华为云码道公测版正式发布，为开发者和企业提供具备工程化能力的智能编码解决方案。
回顾中 -
华为云码道-玩转OpenClaw，开启在线养虾模式2026/03/11 周三 19:00-20:00
刘昱，华为云高级工程师/谈心，华为云技术专家/李海仑，上海圭卓智能科技有限公司CEO
OpenClaw 火爆开发者圈，华为云码道最新推出 Skill ——开发者只需输入一句口令，即可部署一个功能完整的「小龙虾」智能体。直播带你玩转华为云码道，玩转OpenClaw
回顾中
热门标签