Skip to content

Commit 3f8a1b4

Browse files
Added names of all contributors in example-pattern.json file and added SchemaRegistryConfig in the Lambda MSK Event Source in the Consumer Lambda
1 parent 971a1ce commit 3f8a1b4

File tree

3 files changed

+20
-1
lines changed

3 files changed

+20
-1
lines changed

msk-lambda-schema-avro-java-sam/MSKAndKafkaClientEC2.yaml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -551,7 +551,7 @@ Resources:
551551
#Checkout Serverless Patterns from Github
552552
cd /home/ec2-user
553553
SERVERLESS_LAND_GITHUB_LOCATION=${serverless_land_github_location}
554-
git clone $SERVERLESS_LAND_GITHUB_LOCATION
554+
git clone -b feature/avro-code-generation $SERVERLESS_LAND_GITHUB_LOCATION
555555
cd ./serverless-patterns/msk-lambda-schema-avro-java-sam
556556
cp template_original.yaml template.yaml
557557
sudo chown -R ec2-user .

msk-lambda-schema-avro-java-sam/example-pattern.json

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -83,6 +83,16 @@
8383
"name": "Adam Wagner",
8484
"bio": "AWS - Principal Serverless Solutions Architect",
8585
"linkedin": "https://www.linkedin.com/in/adam-wagner-4bb412/"
86+
},
87+
{
88+
"name": "Philipp Page",
89+
"bio": "AWS - SA Engineer",
90+
"linkedin": "https://www.linkedin.com/in/philipp-page/"
91+
},
92+
{
93+
"name": "Leandro Cavalcante Damascena",
94+
"bio": "AWS - Sr. SA Engineer",
95+
"linkedin": "https://www.linkedin.com/in/leandrodamascena/"
8696
}
8797
]
8898
}

msk-lambda-schema-avro-java-sam/template_original.yaml

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -50,6 +50,15 @@ Resources:
5050
DestinationConfig:
5151
OnFailure:
5252
Destination: !GetAtt ConsumerDLQ.Arn
53+
ProvisionedPollerConfig:
54+
MaximumPollers: 3
55+
MinimumPollers: 1
56+
SchemaRegistryConfig:
57+
SchemaRegistryURI: !Sub 'arn:aws:glue:${AWS::Region}:${AWS::AccountId}:registry/${GlueSchemaRegistryName}'
58+
SchemaRegistryURI: !Join [ '', ["arn:", "aws:", "glue:", !Ref "AWS::Region" , ":" ,!Ref "AWS::AccountId", ":", "registry/", !Ref GlueSchemaRegistryName] ]
59+
EventRecordFormat: SOURCE
60+
SchemaValidationConfigs:
61+
- Attribute: VALUE
5362
FilterCriteria:
5463
Filters:
5564
- Pattern: '{ "value": { "zip": [ { "prefix": "2000" } ] }}'

0 commit comments

Comments
 (0)