一、消费者组原理 Consumer Group（CG）：消费者组，由多个consumer组成。形成一个消费者组的条...[作者空间]
一、消费方式 1.pull（ 拉）模式 consumer采用从broker中主动拉取数据。 Kafka采用这种方式...[作者空间]
前言 在一些流数据用例场景中，用户希望将数据长时间存储在流中。虽然 Apache Pulsar 对topic ba...[作者空间]
前言 在事务消息未出现前，Pulsar中支持的最高等级的消息传递保证，是通过Broker的消息去重机制，来保证Pr...[作者空间]
一、添加pom.xml依赖 二、Pulsar 参数类 三、Pulsar 配置类 四、不同消费数据类型的监听器 五、...[作者空间]
一、Pulsar 介绍 Apache Pulsar 作为 Apache 软件基金会顶级项目，是下一代云原生分布式消...[作者空间]
1 Kafka 1.1 定义 Kafka 是一个分布式流媒体平台，kafka官网：http://kafka.apa...[作者空间]
一、Kafka 核心 API 下图是官方文档中的一个图，形象的描述了能与 Kafka集成的客户端类型 Kafka的...[作者空间]
很多情况大数据集群需要获取业务数据，用于分析。通常有两种方式： 业务直接或间接写入的方式 业务的关系型数据库同步到...[作者空间]
背景 在数据仓库建模中，未经任何加工处理的原始业务层数据，我们称之为ODS(Operational Data St...[作者空间]
业务背景 基站同时发送3g和4g的信令到本地文件，通过flume将本地文件接入到kafka的某个topic中。在这...[作者空间]
