Fix an infinite loop in Kafka

This commit is contained in:
M. Mert Yildiran 2021-08-23 00:50:45 +03:00
parent 674041f014
commit c1dee83833
No known key found for this signature in database
GPG Key ID: D42ADB236521BF7A

View File

@ -38,9 +38,15 @@ func (d dissecting) Ping() {
func (d dissecting) Dissect(b *bufio.Reader, isClient bool, tcpID *api.TcpID, emitter api.Emitter) {
for {
if isClient {
ReadRequest(b, tcpID)
_, _, err := ReadRequest(b, tcpID)
if err != nil {
break
}
} else {
ReadResponse(b, tcpID, emitter)
err := ReadResponse(b, tcpID, emitter)
if err != nil {
break
}
}
}
}