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(