14.生产者发送到 Kafka集群的详细流程
2022-06-26 15:11:07 0 举报
生产者发送到 Kafka集群的详细流程
作者其他创作
大纲/内容
{nodeId->List}
buffer pool
request
node1
batch
kafkachannel
avaliableMemory
serializer
主线程
kafkaProducer
metadata
broker
node2
RecordAccumulator
tp1
tp0
InflightRequests
{topicPartition->Deque}
sender线程
selector
ProducerRecord
tp2
消息
free
partitioner
node0
sender
interceptors
0 条评论
回复 删除
下一页