fix(kafka): add kafka response awaiting timeout to config

Gerald Baulig · Gerald Baulig · commit 27529ea597b1 · 2025-02-21T12:24:51.000+01:00
diff --git a/cfg/config.json b/cfg/config.json
@@ -131,6 +131,7 @@
       "provider": "kafka",
       "groupId": "restore-fulfillment-srv",
       "latestOffset": false,
+      "timeout": 15000,
       "kafka": {
         "clientId": "restore-fulfillment-srv",
         "brokers": [
diff --git a/src/services/fulfillment.ts b/src/services/fulfillment.ts
@@ -277,6 +277,7 @@ export class FulfillmentService
     )
 
     this.tech_user = cfg?.get('authorization:techUser');
+    this.kafka_timeout = cfg.get('events:kafka:timeout') ?? 5000;
   }
 
   protected async aggregateProductBundles(

Original file line number	Diff line number	Diff line change
`@@ -277,6 +277,7 @@ export class FulfillmentService`
`277`	`277`	`)`
`278`	`278`
`279`	`279`	`this.tech_user = cfg?.get('authorization:techUser');`
	`280`	`+ this.kafka_timeout = cfg.get('events:kafka:timeout') ?? 5000;`
`280`	`281`	`}`
`281`	`282`
`282`	`283`	`protected async aggregateProductBundles(`