一、消息发送 1.1 数据生产流程 数据生产流程图解: Producer创建时,会创建?个Sender线程并设置为守护线程 ?产消息时,内部其实是异步流程;?产的消息先经过拦截器->序列化器->分区器,然后将消息缓存在缓冲区(该缓冲区也是在Producer创建时创建) 批次发送的条件为:缓冲区数据?
一、消息发送 1.1 数据生产流程 数据生产流程图解: Producer创建时,会创建?个Sender线程并设置为守护线程 ?产消息时,内部其实是异步流程;?产的消息先经过拦截器->序列化器->分区器,然后将消息缓存在缓冲区(该缓冲区也是在Producer创建时创建) 批次发送的条件为:缓冲区数据?