diff --git a/agent/pkg/api/realtime_client.go b/agent/pkg/api/realtime_client.go
index 7fd3bb7a0..a19ee0c34 100644
--- a/agent/pkg/api/realtime_client.go
+++ b/agent/pkg/api/realtime_client.go
@@ -68,6 +68,8 @@ func readConnectionSingle(wg *sync.WaitGroup, conn net.Conn, entry *map[string]i
 	defer wg.Done()
 	for {
 		scanner := bufio.NewScanner(conn)
+		buf := make([]byte, 0, 64*1024)
+		scanner.Buffer(buf, 209715200)
 
 		for {
 			ok := scanner.Scan()
@@ -76,6 +78,13 @@ func readConnectionSingle(wg *sync.WaitGroup, conn net.Conn, entry *map[string]i
 			command := handleCommands(text)
 			if !command {
 				fmt.Printf("\b\b** %s\n> ", text)
+
+				if text == "" {
+					err := scanner.Err()
+					fmt.Printf("err: %v\n", err)
+					return
+				}
+
 				if err := json.Unmarshal([]byte(text), entry); err != nil {
 					panic(err)
 				}