fix(event-factory): include bootstrapServers for msk

driimus · Jan 22, 2024 · 5dad2a8 · 5dad2a8
1 parent fc8c2a0
commit 5dad2a8
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/packages/aws-event-factory/src/msk.ts b/packages/aws-event-factory/src/msk.ts
@@ -25,12 +25,14 @@ export const mskEventFactory = Factory.define<MSKEvent, { topic: string; partiti
       eventSource: 'aws:kafka',
       eventSourceArn:
         'arn:aws:kafka:sa-east-1:123456789012:cluster/vpc-2priv-2pub/751d2973-a626-431c-9d4e-d7975eb44dd7-2',
+      bootstrapServers:
+        'b-2.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092,b-1.demo-cluster-1.a1bcde.c1.kafka.us-east-1.amazonaws.com:9092',
       records: Object.fromEntries(
         Array.from({ length: partitions }, (_v, partition) => [
           `${topic}-${partition}`,
           mskRecordFactory.buildList(1, { topic, partition }),
-        ])
+        ]),
       ),
     };
-  }
+  },
 );