Skip to content

Commit 0019737

Browse files
change kafkaEvent from self-managed to MSK
1 parent 3d9dd70 commit 0019737

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

tests/events/kafkaEvent.json

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,6 @@
11
{
2-
"eventSource":"aws:SelfManagedKafka",
2+
"eventSource":"aws:kafka",
3+
"eventSourceArn":"arn:aws:kafka:us-east-1:0123456789019:cluster/SalesCluster/abcd1234-abcd-cafe-abab-9876543210ab-4",
34
"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",
45
"records":{
56
"mytopic-0":[
@@ -31,4 +32,4 @@
3132
}
3233
]
3334
}
34-
}
35+
}

0 commit comments

Comments
 (0)