From 422bf44a08324c166da8c0033d1ba51944d666e4 Mon Sep 17 00:00:00 2001 From: Lakshay Kalbhor Date: Thu, 9 May 2024 16:55:48 +0530 Subject: [PATCH] chore: add debug log for consumer fetches --- internal/relay/relay.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/internal/relay/relay.go b/internal/relay/relay.go index 31f22dd..982d5d1 100644 --- 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() } }