From 4aacf73ef21b20a2eba518053fb71ddf46f1a880 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=97=BA=E6=B1=AA?= <2246521484@qq.com> Date: Fri, 7 Jan 2022 20:03:25 +0800 Subject: [PATCH] Update capture.go (#1040) Avoid Kafka message output. --- capture/capture.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/capture/capture.go b/capture/capture.go index c6dfd4f..d573fb0 100644 --- a/capture/capture.go +++ b/capture/capture.go @@ -357,8 +357,9 @@ func http1EndHint(m *tcp.Message) bool { if m.MissingChunk() { return false } - - return proto.HasFullPayload(m, m.PacketData()...) + + req, res := http1StartHint(m.Packets()[0]) + return proto.HasFullPayload(m, m.PacketData()...) && (req || res) } func (l *Listener) read() {