一、Pulsar 介绍 Apache Pulsar 是 Apache 软件基金会的顶级项目,是下一代云原生分布式消息流平台,集消息、存储、轻量化函数式计算为一体,采用计算与存...
一、Pulsar 介绍 Apache Pulsar 是 Apache 软件基金会的顶级项目,是下一代云原生分布式消息流平台,集消息、存储、轻量化函数式计算为一体,采用计算与存...
一、前言 老周这里编译 Kafka 的版本是 2.7,为啥采用这个版本来搭建源码的阅读环境呢?因为该版本相对来说比较新。而我为啥不用 2.7 后的版本呢?比如 2.8,这是因...
一、环境准备 老周这里编译 Pulsar 的版本是 2.9.1,也是 Pulsar 目前最新的版本。 JDK:1.8.0_241 Maven:3.6.1 Pulsar:apa...
一、集群搭建要求 1.1 搭建设计 搭建 Pulsar 集群至少需要 3 个组件:ZooKeeper 集群、Bookkeeper 集群和 Broker 集群(Broker 是...
[TOC]本篇算是 Controller 部分的最后一篇,在前面讲述 ReplicaManager 时,留一个地方没有讲解,是关于 Broker 对 Controller 发...
[TOC] 1. 准备工作 1.1 安装好jdk、scala sdk 1.2 安装好gradle gradle版本不能太高 1.3 本地安装好zookeeper并运行; 这里...
[TOC]Kafka 源码解析就正式进入了 Controller 部分,Controller 作为 Kafka Server 端一个重要的组件,它的角色类似于其他分布式系统 ...
数据仓库系列文章 数仓架构发展史[https://www.ikeguang.com/?p=1582] 数仓建模方法论[https://www.ikeguang.com/?p=...
Operator实例只有一个输入流和Source端只有一个流的区别是? 只有一个Source存在多个并行度就会导致可能出现一个Operator实例有多个输入流的情况对吗?如果多个Source源呢?比如两个source进行了union操作那么下游怎么对齐?
Flink--Checkpoint机制原理基于flink-1.8.1 本文转载自一文搞懂Flink内部的Exactly Once和At Least Once 如何理解flink中state(状态) state泛指 s...