chore: add debug log for consumer fetches

zerodha · May 9, 2024 · 422bf44 · 422bf44
1 parent 311a680
commit 422bf44
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/relay/relay.go b/internal/relay/relay.go
@@ -196,6 +196,7 @@ loop:
 				re.log.Debug("marking server as unhealthy", "server", server.ID)
 			}
 
+			re.log.Debug("received fetches", "len", fetches.NumRecords())
 			iter := fetches.RecordIter()
 			for !iter.Done() {
 				rec := iter.Next()
@@ -210,6 +211,7 @@ loop:
 				}
 			}
 
+			re.log.Debug("processed fetches")
 			server.Client.AllowRebalance()
 		}
 	}