fix: add timneout to unified consumer and update throttle map immediately in admin-alert-servuce

Author: Adhish-Krishna

src/admin-alerts/admin-alert.service.ts

@@ -61,12 +61,15 @@ export class AdminAlertService {
                 enabled: true,
                 [filterField]: true,
             });
-
+            
             // No channels configured - silent no-op (backwards compatible)
             if (channels.length === 0) {
                 return;
             }
-
+            
+            // Update throttle timestamp
+            throttleMap.set(alertType, Date.now());
+            
             // Get encryption key (auto-creates if needed)
             const encryptionKey = await getOrCreateEncryptionKey();
 
@@ -101,8 +104,6 @@ export class AdminAlertService {
                 }
             }
 
-            // Update throttle timestamp
-            throttleMap.set(alertType, Date.now());
         } catch (err) {
             // Never throw - admin alerts are non-critical to core functionality
             logger.error('AdminAlertService.sendAlert failed:', err);

src/processors/unified/unified.consumer.ts

@@ -374,7 +374,13 @@ export const startUnifiedConsumer = async (channel: string): Promise<void> => {
 
     logger.info(`[${channel}] Creating consumer for topic: ${topic}, group: ${groupId}`);
 
-    const consumer = kafka.consumer({ groupId });
+    const consumer = kafka.consumer({
+        groupId,
+        sessionTimeout: 30000,
+        rebalanceTimeout: 60000,
+        heartbeatInterval: 3000,
+    });
+    
     await consumer.connect();
     await consumer.subscribe({ topic, fromBeginning: false });