kafka通信协议(二)

原创
2017/11/22 20:32
阅读数 1.4K

1. produce抓包

通过sarama(go客户端)向kafka中名为"test"的topic发送一条消息,其内容为"hello world"。

  • 具体的抓包内容如下

  • 前面两个请求为SASL握手及认证

  • 最后为Produce请求

  • produce请求的响应

2. consuemr抓包

通过sarama向kafka中名为"test"的topic进行消息的消费。

具体的抓包内容

注:首先建立连接向Broker获取元数据信息,然后建立连接向topic的partition消费消息。

  • Metadata请求

  • ListOffsets请求

注:实际上进行了两次请求,两次请求的时间戳分别为-1、-2,响应结果的offset也有区别。

  • Fetch请求

  • fetch请求响应结果

展开阅读全文
加载中
点击引领话题📣 发布并加入讨论🔥
打赏
0 评论
0 收藏
0
分享
返回顶部
顶部