分类： Kafka

假如咱们音讯要发送到192.168.1.10的broker中，假如ID为1，在建设连贯的时候，会在缓存中，保留…

Kafka是一个 Scala 语言开发的多分区、多正本、分布式的基于公布/订阅模式的音讯队列。目前 Kafka…

咱们数据都写入了缓冲区，那这里的数据不可能始终放在缓存里的，所以kafka有一个线程，叫做Sender，这个线…

一、Producer 的网络模型咱们后面几篇有说 Producer 发送流程的源码剖析，但那个是大的轮廓，波及…

kafka在音讯指定好分区后，并没有间接把音讯收回去，而是把音讯寄存在内存中，再分批收回去，这样就缩小了网络传…

咱们上一篇说了 聊聊 Kafka：Producer 源码解析，这一篇咱们来说下 Producer Metada…

sarama 是一个纯 Go 客户端库，用于解决 Apache Kafka（0.8 及更高版本）。它包含一个用…

老周这里编译 Kafka 的版本是 2.7，为啥采纳这个版本来搭建源码的浏览环境呢？因为该版本相对来说比拟新。…

cluster：kafka集群broker：kafka节点topic：主题partation：音讯分区（一个t…

在构建ProducerRecord的时候说过，ProducerRecord除了topic和value外，还有两…