Kafka消息发送机制

1.1 消息发送核心流程 1.2 生产者初始化主要过程 1.3 消息发送具体流程 1.4 生产者内存池设计 1.1 消息发送核心流程   1.2 生产者初始化主要过程 1、设置分区器 2、设置重试机制  retry.backoff.ms，默认100ms 3、设置序列化器 4、设置拦截器（国过滤器），意义不大 5、设置获取元数据metadata（每隔5min自动更新一下元数据） 6、设置单条消息大小

>>阅读原文<<