chore: add debug log for consumer fetches

Lakshay Kalbhor · Lakshay Kalbhor · commit 422bf44a0832 · 2024-05-09T16:55:48.000+05:30
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()
 		}
 	}

Original file line number	Diff line number	Diff line change
`@@ -196,6 +196,7 @@ loop:`
`196`	`196`	`re.log.Debug("marking server as unhealthy", "server", server.ID)`
`197`	`197`	`}`
`198`	`198`
	`199`	`+ re.log.Debug("received fetches", "len", fetches.NumRecords())`
`199`	`200`	`iter := fetches.RecordIter()`
`200`	`201`	`for !iter.Done() {`
`201`	`202`	`rec := iter.Next()`
`@@ -210,6 +211,7 @@ loop:`
`210`	`211`	`}`
`211`	`212`	`}`
`212`	`213`
	`214`	`+ re.log.Debug("processed fetches")`
`213`	`215`	`server.Client.AllowRebalance()`
`214`	`216`	`}`
`215`	`217`	`}`