本文主要简略记录kafka开启sasl认证后发送消息源码各步骤耗时分析及SASL状态变更过程
【环境】 JAVA语言 使用Spring Kafka相关jar进行开发
【起源】主要由于特殊网络环境下kafka开启sasl认证前后kakfa耗时太长,需要进行根因定位
在此过程中开启kakfa trace级别日志 针对日志及源码进行流程绘制分析
【分析过程】主要针对kafka client包中的 kafka producer类的doSend方法进行分析,主要数据来源于kafka 本身打印的日志
【耗时太长方案】 分析过程后有定位根因,不在本文叙述,有兴趣可另见 本专栏文章-Kafka发送消息耗时太长排查