KafkaProducer概览
2020-10-16 09:48:55 0 举报KafkaProducer概览
作者其他创作
大纲/内容
future
TopicPartition
accumulator
interceptors
Kafka Server
List
partitioner
……
MemoryRecords
append
ByteBuffer
KafkaProducer
sender
…
partition
callback
RecordBatch
List requests
应用程序
boolean needUpdate
ClientRequest
Set readyNodes
MetadataUpdater
NetworkClient
网络
id
ip
networkClient
Sender
value
BufferPool free
InFlightRequests
ClusterConnectionStates
serializer
KafkaSelector
RecordAccumulator
key
RecordAccumulator.ReadyCheckResult
Cluster
metadata
wakeup()
topic
Set muted
RequestSend
收藏
收藏
0 条评论
下一页
