Skip to content

Commit 150623b

Browse files
anafalcaoAna Falcao
and
Ana Falcao
authored
fix(parser): remove 'aws:' prefix from SelfManagedKafka model (#5584)
remove the aws: from the SelfManagedKafka Co-authored-by: Ana Falcao <[email protected]>
1 parent 5f64029 commit 150623b

File tree

2 files changed

+34
-34
lines changed

2 files changed

+34
-34
lines changed

aws_lambda_powertools/utilities/parser/models/kafka.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -50,7 +50,7 @@ class KafkaSelfManagedEventModel(KafkaBaseEventModel):
5050
- https://docs.aws.amazon.com/lambda/latest/dg/with-kafka.html
5151
"""
5252

53-
eventSource: Literal["aws:SelfManagedKafka"]
53+
eventSource: Literal["SelfManagedKafka"]
5454

5555

5656
class KafkaMskEventModel(KafkaBaseEventModel):
+33-33
Original file line numberDiff line numberDiff line change
@@ -1,34 +1,34 @@
11
{
2-
"eventSource":"aws:SelfManagedKafka",
3-
"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",
4-
"records":{
5-
"mytopic-0":[
6-
{
7-
"topic":"mytopic",
8-
"partition":0,
9-
"offset":15,
10-
"timestamp":1545084650987,
11-
"timestampType":"CREATE_TIME",
12-
"key":"cmVjb3JkS2V5",
13-
"value":"eyJrZXkiOiJ2YWx1ZSJ9",
14-
"headers":[
15-
{
16-
"headerKey":[
17-
104,
18-
101,
19-
97,
20-
100,
21-
101,
22-
114,
23-
86,
24-
97,
25-
108,
26-
117,
27-
101
28-
]
29-
}
30-
]
31-
}
32-
]
33-
}
34-
}
2+
"eventSource": "SelfManagedKafka",
3+
"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",
4+
"records": {
5+
"mytopic-0": [
6+
{
7+
"topic": "mytopic",
8+
"partition": 0,
9+
"offset": 15,
10+
"timestamp": 1545084650987,
11+
"timestampType": "CREATE_TIME",
12+
"key": "cmVjb3JkS2V5",
13+
"value": "eyJrZXkiOiJ2YWx1ZSJ9",
14+
"headers": [
15+
{
16+
"headerKey": [
17+
104,
18+
101,
19+
97,
20+
100,
21+
101,
22+
114,
23+
86,
24+
97,
25+
108,
26+
117,
27+
101
28+
]
29+
}
30+
]
31+
}
32+
]
33+
}
34+
}

0 commit comments

Comments
 (0)