Kafka

2022年5月6日 · 7287 字 · 15 分钟 · Kafka

一、Kafka 消费方式pull（拉）模式： consumer 采用从 broker 中主动拉取数据。 Kafka 采用这种方式。 push（推）模式： Kafka 没有采用这种方式，因为由 broker 决定消息

2022年5月6日 · 5698 字 · 12 分钟 · Kafka

一、Kafka Broker 工作流程1.1、Zookeeper 存储的 Kafka 信息（1）启动 Zookeeper 客户端。 bin/zkCli.sh （2）通过 ls 命令可以查看 kafka 相关信息。 ls /kafka Zookeeper 中存储的 Kafka 信息

2022年5月6日 · 4979 字 · 10 分钟 · Kafka

一、生产者消息发送流程1.1、发送原理在消息发送的过程中，涉及到了两个线程：main 线程和 Sender 线程。在 main 线程中创建了一个双端队列 RecordA

2022年5月6日 · 2767 字 · 6 分钟 · Kafka

一、概述1.1、定义Kafka 传统定义：Kafka 是一个分布式的基于发布/订阅模式的消息队列 Message Queue，主要应用于大数据实时处理领域。 Kafka 最