京东内部使用基于 Apache Kafka 构建的 JDQ 来支持其平台业务。JDQ 是京东集团大数据平台统一的实时数据总线，赋能集团内部京东零售、物流、科技、...

以下案例研究展示了 Kafka 在四个关键领域的卓越表现：实时数据处理、消息传递、运营指标和日志聚合。

在3.5版本发布后，Zookeeper已被标记为弃用并推荐使用KRaft模式部署kakfa集群，但是官方手册也提到了KRaft中仍有一小部分功能有待实现，所以个...

现场大数据项目Kafka组件大多数使用的语言集中在Java、Python、Go、C++。最近现场需求使用Erlang对接，遂有本文。Erlang是一种函数式并发...

Kafka消费者组中的消息消费模型有两种，即：推送模式（push）和拉取模式（pull）。视频讲解如下：

在 Apache Kafka 中，Broker 是指 Kafka 集群中的一个节点（或服务器）。它是 Kafka 系统的核心组件之一，负责存储和管理消息数据，并...

消费者就是从Kafka集群消费数据的客户端，下图展示了一个消费者从主题中消费数据的模型。

Apache Kafka 是一个分布式流处理平台，最初由 LinkedIn 开发，并于 2011 年开源。Kafka 的设计目标是提供高吞吐量、低延迟的消息传递...

Kafka生产者有三种方式进行消息的发送，这三种方式区别在于对于消息是否正常到达的处理。视频讲解如下：

Kafka的生产者Producer将消息序列化之后，发送到对应主题的指定分区上。下图为展示了生产者的执行过程。

这些都是免费的公共动态库，在 Nuget 上都可以搜索到 [ 搜索格式: Snet.* ]

针对问题2，kafka 提供两类消息发送方式：同步（sync）发送和异步（async）发送，trpc-go 框架中kafka插件相关参数如下：

Apache Doris 提供多维度数据摄入能力，除内置 Routine Load 及 Flink 支持读取 Kafka 写入 Doris 方案外，Doris ...

Kafka 本身的设计并不支持传统的读写分离，这主要是由于其架构和设计目标决定的。以下是 Kafka 不支持读写分离的主要原因：

在两台机器上(以slave1，slave2为例)，分别部署一个broker，Zookeeper使用的是单独的集群，然后创建一个topic，启动模拟的生产者和消费...

7、Offset：kafka 的存储文件都是按照 offset.kafka 来命名，用 offset 做名字的好处是方便查找。例如你想找位于 2049 的位置，...

Apache Kafka 是一个流行的分布式消息传递系统，广泛用于构建实时数据管道和流应用程序。它以高吞吐量、内置的分区、副本和容错性著称。Kafka 主要提供...

Apache ZooKeeper 在 Apache Kafka 的架构中扮演着至关重要的角色。作为一个分布式协调服务，ZooKeeper 提供一致性和同步，确保...

Kafka是一个分布式流处理平台，它以高吞吐量、可扩展性和容错性而闻名。在Kafka中，Topic是消息流的逻辑容器，用于组织和存储消息。让我们通过Java代码...

Kafka就像一个忙碌的新闻发布站，它能够处理和分发大量的实时信息。通过新闻发布站的比喻来详细解释Kafka中的各个知识点、设计思想，结合具体的代码和面试常问的...