Skip to content

Commit 5350afe

Browse files
authored
fix(parser): event type literal for selfManagedKafka (#3325)
1 parent de1ee89 commit 5350afe

File tree

3 files changed

+3
-4
lines changed

3 files changed

+3
-4
lines changed

Diff for: .husky/pre-push

-1
Original file line numberDiff line numberDiff line change
@@ -4,5 +4,4 @@ npm t \
44
npx vitest --run \
55
--exclude tests/unit/layer-publisher.test.ts \
66
--coverage --coverage.thresholds.100 \
7-
--changed="$(git merge-base HEAD main)" \
87
tests/unit

Diff for: packages/parser/src/schemas/kafka.ts

+2-2
Original file line numberDiff line numberDiff line change
@@ -40,7 +40,7 @@ const KafkaBaseEventSchema = z.object({
4040
* @example
4141
* ```json
4242
* {
43-
* "eventSource":"aws:SelfManagedKafka",
43+
* "eventSource":"SelfManagedKafka",
4444
* "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",
4545
* "records":{
4646
* "mytopic-0":[
@@ -79,7 +79,7 @@ const KafkaBaseEventSchema = z.object({
7979
* @see {@link https://docs.aws.amazon.com/lambda/latest/dg/with-kafka.html}
8080
*/
8181
const KafkaSelfManagedEventSchema = KafkaBaseEventSchema.extend({
82-
eventSource: z.literal('aws:SelfManagedKafka'),
82+
eventSource: z.literal('SelfManagedKafka'),
8383
});
8484

8585
/**

Diff for: packages/parser/tests/events/kafkaEventSelfManaged.json

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
{
2-
"eventSource": "aws:SelfManagedKafka",
2+
"eventSource": "SelfManagedKafka",
33
"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",
44
"records": {
55
"mytopic-0": [

0 commit comments

Comments
 (0)