kafka通信协议(二)

2019独角兽企业重金招聘Python工程师标准>>>

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请求响应结果

转载于:https://my.oschina.net/hncscwc/blog/1577564