From f77f8bc9c21ef090ce1dc49e9b444bda286053f6 Mon Sep 17 00:00:00 2001
From: "M. Mert Yildiran" <mehmet@up9.com>
Date: Thu, 12 May 2022 21:05:33 +0300
Subject: [PATCH] Add `TODO`

---
 tap/tcp_reader.go | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/tap/tcp_reader.go b/tap/tcp_reader.go
index d7d6ff896..854834385 100644
--- a/tap/tcp_reader.go
+++ b/tap/tcp_reader.go
@@ -100,6 +100,7 @@ func (reader *tcpReader) rewind() {
 func (reader *tcpReader) Read(p []byte) (int, error) {
 	var msg api.TcpReaderDataMsg
 
+	// TODO: There are problems in AMQP and Kafka
 	if reader.exhaustBuffer && len(reader.data) == 0 {
 		if len(reader.msgBuffer) > 0 {
 			// Pop first message
@@ -134,6 +135,7 @@ func (reader *tcpReader) Read(p []byte) (int, error) {
 			reader.packetsSeen += 1
 		}
 	}
+
 	if !ok || len(reader.data) == 0 {
 		return 0, io.EOF
 	}