searchusermenu
  • 发布文章
  • 消息中心
点赞
收藏
评论
分享
原创

kafka开启SASL认证后发送消息过程简记

2023-09-15 09:29:38
12
0

本文主要简略记录kafka开启sasl认证后发送消息源码各步骤耗时分析及SASL状态变更过程

【环境】 JAVA语言 使用Spring Kafka相关jar进行开发

 【起源】主要由于特殊网络环境下kafka开启sasl认证前后kakfa耗时太长,需要进行根因定位

在此过程中开启kakfa trace级别日志 针对日志及源码进行流程绘制分析

【分析过程】主要针对kafka client包中的 kafka producer类的doSend方法进行分析,主要数据来源于kafka 本身打印的日志

kafka发送消息过程

【耗时太长方案】 分析过程后有定位根因,不在本文叙述,有兴趣可另见 本专栏文章-Kafka发送消息耗时太长排查

0条评论
0 / 1000
long
5文章数
0粉丝数
long
5 文章 | 0 粉丝
原创

kafka开启SASL认证后发送消息过程简记

2023-09-15 09:29:38
12
0

本文主要简略记录kafka开启sasl认证后发送消息源码各步骤耗时分析及SASL状态变更过程

【环境】 JAVA语言 使用Spring Kafka相关jar进行开发

 【起源】主要由于特殊网络环境下kafka开启sasl认证前后kakfa耗时太长,需要进行根因定位

在此过程中开启kakfa trace级别日志 针对日志及源码进行流程绘制分析

【分析过程】主要针对kafka client包中的 kafka producer类的doSend方法进行分析,主要数据来源于kafka 本身打印的日志

kafka发送消息过程

【耗时太长方案】 分析过程后有定位根因,不在本文叙述,有兴趣可另见 本专栏文章-Kafka发送消息耗时太长排查

文章来自个人专栏
学海闲记
5 文章 | 1 订阅
0条评论
0 / 1000
请输入你的评论
0
0