Kafka 原理图

Producer

一条Message的基本信息 -  ProducerRecord

主题

msg deque

kafka cluster

pull

send

detail

为什么要使用微批处理呢？原因：将很多小的消息打包成一批次，统一发送，这样减少网络请求，提升吞吐量/次

分区号

Consumer1

Producer03

消息头一般很少设置

4

Consumer3

归类用使用也可以不设置

3

Consumer2

Producer01

2

Consumer4

消息体

Consumer

Broker2

消息发送的时间

Broker1

Producer0N

Producer02

1

topic

patition

headers

key

value

timestamp

Broker3

zookeeper

ProducerBatch