生产者

作者丨Shaolang Ai, 译者 | 杨晓娟, 用Chronicle Queue构建的应用程序不会让生产者放慢将消息放入队列的速度（没有背压机制）。, Chronicle Queue(编年史队列...

,本节就一起探讨一下什么是阻塞队列，一起来看下吧！,我们先说一下为什么要引入阻塞队列。我们知道服务器的资源是有限的，就拿典型的生产者和消费者模型来讲。,消费者如果没有东西可以消费了，但是它还是在一直执...

从今天开始我将以「 Kafka 2.7」 版本为主，通过「场景驱动」的方式带大家一点点的对 Kafka 源码进行深度剖析，正式开启 「Kafka的源码之旅」，跟我一起来掌握 Kafka 源码核心架构设...

大家好，我是 华仔, 又跟大家见面了。,在上一篇中，正式开启了「Kafka的源码之旅」，主要讲述了 KafkaProducer 初始化时用到的核心组件以及消息发送的核心流程，带你梳理生产者初始化整体的...

,​虽然流可以是处理大量数据的有效方式，但它们也有自己的挑战。让我们看看其中的一些。,1. 如果消费者无法像制作人创建块那样快速处理块，会发生什么？一个例子：如果消费者比生产者慢50%，会怎么样？如果...