Skip to content

Commit

Permalink
Merge pull request #2524 from indranilbanerjeeawssa/main
Browse files Browse the repository at this point in the history
Fixing msk-lambda-iam-python-sam and msk-lambda-iam-node-sam projects by adding Cloudformation templates as previous CFT doesn't work anymore due to Cloud9 dependency
  • Loading branch information
julianwood authored Feb 4, 2025
2 parents ffd3795 + fd57c48 commit 5cb6cd8
Show file tree
Hide file tree
Showing 8 changed files with 2,787 additions and 159 deletions.
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

0 comments on commit 5cb6cd8

Please sign in to comment.