Added logging in backend router

2021-01-12 19:53:28 +02:00
parent 44f841959b
commit e86876b252
1 changed files with 2 additions and 0 deletions
@@ -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(