From fe9ee2afce277c8c095c9804679736ac07cde989 Mon Sep 17 00:00:00 2001 From: Ana Falcao Date: Mon, 18 Nov 2024 18:30:56 -0300 Subject: [PATCH] remove the aws: from the SelfManagedKafka --- .../utilities/parser/models/kafka.py | 2 +- tests/events/kafkaEventSelfManaged.json | 66 +++++++++---------- 2 files changed, 34 insertions(+), 34 deletions(-) diff --git a/aws_lambda_powertools/utilities/parser/models/kafka.py b/aws_lambda_powertools/utilities/parser/models/kafka.py index 4969f7f427b..447b96c406b 100644 --- a/aws_lambda_powertools/utilities/parser/models/kafka.py +++ b/aws_lambda_powertools/utilities/parser/models/kafka.py @@ -50,7 +50,7 @@ class KafkaSelfManagedEventModel(KafkaBaseEventModel): - https://docs.aws.amazon.com/lambda/latest/dg/with-kafka.html """ - eventSource: Literal["aws:SelfManagedKafka"] + eventSource: Literal["SelfManagedKafka"] class KafkaMskEventModel(KafkaBaseEventModel): diff --git a/tests/events/kafkaEventSelfManaged.json b/tests/events/kafkaEventSelfManaged.json index 22985dd11dd..eaf0bf34cae 100644 --- a/tests/events/kafkaEventSelfManaged.json +++ b/tests/events/kafkaEventSelfManaged.json @@ -1,34 +1,34 @@ { - "eventSource":"aws: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":[ - { - "topic":"mytopic", - "partition":0, - "offset":15, - "timestamp":1545084650987, - "timestampType":"CREATE_TIME", - "key":"cmVjb3JkS2V5", - "value":"eyJrZXkiOiJ2YWx1ZSJ9", - "headers":[ - { - "headerKey":[ - 104, - 101, - 97, - 100, - 101, - 114, - 86, - 97, - 108, - 117, - 101 - ] - } - ] - } - ] - } -} + "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": [ + { + "topic": "mytopic", + "partition": 0, + "offset": 15, + "timestamp": 1545084650987, + "timestampType": "CREATE_TIME", + "key": "cmVjb3JkS2V5", + "value": "eyJrZXkiOiJ2YWx1ZSJ9", + "headers": [ + { + "headerKey": [ + 104, + 101, + 97, + 100, + 101, + 114, + 86, + 97, + 108, + 117, + 101 + ] + } + ] + } + ] + } +} \ No newline at end of file