前言 相信大家都使用过消息MQ,他可以很好地进行系统解耦,减低变成的复杂度,又可以进行削峰,增加系统在高并发的稳定...[作者空间]
1. 什么是Apache Kafka? 答:Apache Kafka是一个发布 - 订阅开源消息代理应用程序。这个...[作者空间]
Apache Bookkeeper的启动流程解析 全局main函数实现 启动代码 位于bookkeeper-ser...[作者空间]
说在前面 RocketMQ在底层存储上借鉴了Kafka,但是也有它独到的设计,本文主要关注深刻影响着RocketM...[作者空间]
文章摘要:上篇中主要介绍了RocketMQ存储部分的整体架构设计,本篇将深入分析RocketMQ存储部分的细节内容...[作者空间]
文章摘要:MQ分布式消息队列大致流程在于消息的一发一收一存,本篇将为大家主要介绍下RocketMQ存储部分的架构消...[作者空间]
待询问的问题: 安全 插件 CHAS 备机接管 暖场 目前正在考虑多语言的支持,后续新增C++, PYTHON, ...[作者空间]
文章摘要:在阿里云上,就创建了一个消息队列的Topic,其他啥也没干,过了一天就欠阿里云2元了,消息队列这项云服务...[作者空间]
开篇 整个博文希望能够讲清楚Disruptor的producer和consumer的处理过程以及两者之间的消息通...[作者空间]
应用程序使用 KafkaConsumer向 Kafka 订阅主题,并从订阅的主题上接收消息 。 从 Kafka 读...[作者空间]
摘要:如果Consumer端消费消息失败,那么RocketMQ是如何对失败的异常情况进行处理?前面两篇Rocket...[作者空间]
摘要:在RocketMQ中,消息消费都是基于Pull消息方式,那么Push模式中又是如何实现Consumer端准实...[作者空间]
前言 记得前段时间我们生产上的一个网关出现了故障。 这个网关逻辑非常简单,就是接收客户端的请求然后解析报文最后发送...[作者空间]
1 Kafka介绍 Kafka是最初由Linkedin公司开发,是一个分布式、支持分区的(partition)、多...[作者空间]
许久不写文章,主要是心情不佳,而且恰逢项目方向变动,学习和研究都放下了不少。最近开始主攻Kafka,在了解Kafk...[作者空间]
kafka是一个分布式发布订阅消息系统。由LinkedIn开发并已经在2011年7月成为apache顶级项目。ka...[作者空间]
这篇文章是关于LinkedIn如何用kafka作为一个中央发布-订阅日志,在应用程序,流处理,hadoop数据提取...[作者空间]
摘要:消息存储对于每一款消息队列都非常重要,那么Kafka在这方面是如何来设计做到高效的呢?Kafka这款分布式消...[作者空间]
文章摘要:在发送消息给RocketMQ后,消费者需要消费。消息的消费比发送要复杂一些,那么RocketMQ是如何来...[作者空间]
消费者如何分配分区就是指某个topic,其N个分区和消费该topic的若干消费者群组下M个消费者的关系。如下图所示...[作者空间]