Kafka作为一个分布式的流平台，这到底意味着什么？我们认为，一个流处理平台具有三个关键能力：1. 发布和订阅消息(流)，在这方面，它类似于一个消息队列。2. 以容错(故障转移)的方式存储消息(流)。3. 在消息流发生时处理它们。 什么是kafka的优势？它主要应用于2大类应用：1. 构建实时的流...

kafka的背景知识已经讲了很多了，让我们现在开始实践吧，假设你现在没有`Kafka`和`ZooKeeper`环境。 Step 1: 下载[下载](/66)并且解压它。 $ tar -xzf kafka_2.13-3.7.0.tgz $ cd kafka_2.13-3.7.0 Step ...

你可以登录Apache kafka 官方下载。https://kafka.apache.org/downloads.html--- 注意：别下成源文件了！带`src`的是源文件，如：Source download: kafka-3.7.0-src.tgz (asc, sha512) 你应该下的...

整理kafka相关的常用命令。 管理```long 创建topic（4个分区，2个副本）bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 2 --partitions 4 --topic test...

下面是一些关于`Apache kafka`非常流行的使用场景。这些领域的概述，可查看[博客文章](https://engineering.linkedin.com/distributed-systems/log-what-every-software-engineer-should-know-abo...

支持的版本- `>= 0.9` kafka客户端发布`record(消息)`到kafka集群。新的生产者是线程安全的，在线程之间共享**单个生产者**实例，通常单例比多个实例要快。一个简单的例子，使用producer发送一个有序的key/value(键值对)，放到java的`main`方法里就能直...

Apache Kafka引入一个新的java客户端（在org.apache.kafka.clients 包中），替代老的Scala客户端，但是为了兼容，将会共存一段时间。为了减少依赖，这些客户端都有一个独立的jar，而旧的Scala客户端继续与服务端保留在同个包下。 Kafka有5个核心API：1....

我们鼓励所有新开发的程序使用新的`Java生产者`，新的java生产者客户端比以前的Scala的客户端更快、功能更全面。通过下面的例子，引入Maven（可以更改新的版本号）。```org.apache.kafkakafka-clients3.7.0```如何使用生产者，请点击[这里](/303)。对...

一个从kafka集群中获取消息的java客户端。kafka客户端从kafka集群中获取消息，并透明地处理kafka集群中出现故障broker，透明地调节适应集群中变化的数据分区。也和broker交互，负载平衡消费者。 public class KafkaConsumer extends ...

3.1 Broker配置基本配置如下:* broker.id* log.dirs* zookeeper.connect下文将详细论述了主题级别配置和默认值。 kafka >= 0.10版名称|描述|类型|默认|有效值|重要程度---|---|---|---|---|---|zookeeper.co...