kafka通信协议(二)
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