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

参数介绍- 节点 ip：10.211.55.5- Pod ip：192.168.0.0/16- Servce ip：10.96.0.0/12这3个ip中- **节点 ip**：你自己当前节点机器的IP。- **pod ip**：创建容器时，分配的IP段范围。- **service ip**：负载均...

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

环境centerOS 7.5master：- m1: 10.0.19.91- m2: 10.0.19.92- m3: 10.0.19.93node：- n1: 10.0.19.127- n2: 10.0.19.128负载均衡地址和端口：- 10.0.19.1:8443 开始前[必做]- [安装ku...

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

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

Pod是Kubernetes的最重要也最基本的概念，如图所示是Pod的组成示意图，我们看到每个Pod都有一个特殊的被称为“根容器”的Pause容器。Pause容器对应的镜像属于Kubernetes平台的一部分，除了Pause容器，每个Pod还包含一个或多个紧密相关的用户业务容器。 为什么Kubern...

kafka集群安装搭建接上一步，[单集群](/6)已经搭建好之后。 设置多个broker集群到目前，我们只是单一的运行一个broker，没什么意思。对于Kafka，一个broker仅仅只是一个集群的大小，所有让我们多设几个broker。首先为每个broker创建一个配置文件: cp con...

项目说明通过传入开始和结束时间戳，重新消费kafka历史消息。```public static void main(String[] args) { String startTime = "2018-08-14 21:19:09"; // 开始时间 String endTi...

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