Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1,267 changes: 1,267 additions & 0 deletions msk-lambda-iam-node-sam/MSKAndKafkaClientEC2.yaml

Large diffs are not rendered by default.

194 changes: 132 additions & 62 deletions msk-lambda-iam-node-sam/README.md

Large diffs are not rendered by default.

22 changes: 9 additions & 13 deletions msk-lambda-iam-node-sam/example-pattern.json
Original file line number Diff line number Diff line change
Expand Up @@ -8,10 +8,10 @@
"headline": "How it works",
"text": [
"This pattern provides a Lambda function along with an Event Source Mapping to a Kafka topic.",
"It requires that you already have an Amazon Managed Streaming for Kafka(Amazon MSK) cluster setup with a topic created. If you don't already have an MSK cluster ",
"you can use the example in this pattern https://serverlessland.com/patterns/msk-cfn-sasl-lambda (linked in the resources) to deploy a cluster.",
"It requires that you already have an Amazon Managed Streaming for Kafka(Amazon MSK) cluster setup with a Kafka topic created.",
"The CloudFormation template provided in this pattern installs an MSK Cluster and creates a Kafka topic.",
"This pattern works with either a Provisioned or Serverless MSK cluster as long as the cluster is configured to use IAM authentication. ",
"For detailed deployment instructions instructions see the README "
"For detailed deployment instructions instructions see the README.md"
]
},
"gitHub": {
Expand All @@ -24,10 +24,6 @@
},
"resources": {
"bullets": [
{
"text": "Amazon MSK Cluster pattern",
"link": "https://serverlessland.com/patterns/msk-cfn-sasl-lambda"
},
{
"text": "Using AWS Lambda with Amazon MSK",
"link": "https://docs.aws.amazon.com/lambda/latest/dg/with-msk.html"
Expand Down Expand Up @@ -58,6 +54,11 @@
]
},
"authors": [
{
"name": "Indranil Banerjee",
"bio": "AWS - Senior Solutions Architect",
"linkedin": "https://www.linkedin.com/in/indranil-banerjee-b00a261/"
},
{
"name": "Vaibhav Jain",
"bio": "AWS - Sr. Application Architect",
Expand All @@ -70,7 +71,7 @@
"image": "https://www.fintail.me/images/pa.jpg",
"linkedin": "https://www.linkedin.com/in/pallam/"
},
{
{
"name": "Suraj Tripathi",
"bio": "AWS - AppDev Cloud Consultant",
"linkedin": "https://www.linkedin.com/in/suraj-tripathi-01b49a140/"
Expand All @@ -79,11 +80,6 @@
"name": "Adam Wagner",
"bio": "AWS - Principal Serverless Solutions Architect",
"linkedin": "https://www.linkedin.com/in/adam-wagner-4bb412/"
},
{
"name": "Indranil Banerjee",
"bio": "AWS - Senior Solutions Architect",
"linkedin": "https://www.linkedin.com/in/indranil-banerjee-b00a261/"
}
]
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@ Resources:
Properties:
CodeUri: HandlerKafka/
Handler: app.handler
Runtime: nodejs18.x
Runtime: NODEJS_VERSION
Architectures:
- x86_64
Events:
Expand Down Expand Up @@ -71,12 +71,15 @@ Parameters:
MSKClusterName:
Type: String
Description: Enter the name of the MSK Cluster
Default: CLUSTER_NAME
MSKClusterId:
Type: String
Description: Enter the ID of the MSK Cluster
Default: CLUSTER_ID
MSKTopic:
Type: String
Description: Enter the name of the MSK Topic
Default: KAFKA_TOPIC
Outputs:
LambdaMSKConsumerNodeJSFunction:
Description: "Topic Consumer Lambda Function ARN"
Expand Down
Loading