From e86876b25225f421fa4b5b6f376aebae5d91f4f7 Mon Sep 17 00:00:00 2001 From: Nir Gazit Date: Tue, 12 Jan 2021 19:53:28 +0200 Subject: [PATCH] Added logging in backend router --- plugins/kafka-backend/src/service/router.ts | 2 ++ 1 file changed, 2 insertions(+) diff --git a/plugins/kafka-backend/src/service/router.ts b/plugins/kafka-backend/src/service/router.ts index 9c61e05bcd..621de690d3 100644 --- a/plugins/kafka-backend/src/service/router.ts +++ b/plugins/kafka-backend/src/service/router.ts @@ -36,6 +36,8 @@ export const makeRouter = ( router.get('/consumer/:consumerId/offsets', async (req, res) => { const consumerId = req.params.consumerId; + logger.debug(`Fetch consumer group ${consumerId} offsets`); + const groupOffsets = await kafkaApi.fetchGroupOffsets(consumerId); const groupWithTopicOffsets = await Promise.all(