fix(parser): event type literal for selfManagedKafka (#3325)

aws-powertools · Nov 18, 2024 · 5350afe · 5350afe
1 parent de1ee89
commit 5350afe
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 4 deletions.
diff --git a/.husky/pre-push b/.husky/pre-push
@@ -4,5 +4,4 @@ npm t \
 npx vitest --run \
   --exclude tests/unit/layer-publisher.test.ts \
   --coverage --coverage.thresholds.100 \
-  --changed="$(git merge-base HEAD main)" \
   tests/unit
diff --git a/packages/parser/src/schemas/kafka.ts b/packages/parser/src/schemas/kafka.ts
@@ -40,7 +40,7 @@ const KafkaBaseEventSchema = z.object({
  * @example
  * ```json
  * {
- *   "eventSource":"aws:SelfManagedKafka",
+ *   "eventSource":"SelfManagedKafka",
  *   "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":{
  *      "mytopic-0":[
@@ -79,7 +79,7 @@ const KafkaBaseEventSchema = z.object({
  * @see {@link https://docs.aws.amazon.com/lambda/latest/dg/with-kafka.html}
  */
 const KafkaSelfManagedEventSchema = KafkaBaseEventSchema.extend({
-  eventSource: z.literal('aws:SelfManagedKafka'),
+  eventSource: z.literal('SelfManagedKafka'),
 });
 
 /**

diff --git a/packages/parser/tests/events/kafkaEventSelfManaged.json b/packages/parser/tests/events/kafkaEventSelfManaged.json
@@ -1,5 +1,5 @@
 {
-  "eventSource": "aws:SelfManagedKafka",
+  "eventSource": "SelfManagedKafka",
   "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": {
     "mytopic-0": [