AWS Iot Core, Lambda and Amazon Managed Streaming for Apache Kafka (Amazon MSK) Pipeline

[bigbernnn]

trafficstars

Describe the feature

Deploying the stack creates an IOT Core Rule and destination, which sends messages to an MSK Cluster. Then, a Lambda function consumes these messages from the MSK Cluster topic, which generates logs in CloudWatch. This is a common architecture for customers using MSK instead of Kinesis for streaming IOT data.

Use Case

I built this for a customer demonstration. I could not find any examples MSK as part of a CDK data pipeline. Therefore, it took much longer to build the template than it otherwise would have. This is also a common architecture for customers using MSK instead of Kinesis for streaming IOT data.

Proposed Solution

I have already built the template.

Other Information

No response

Acknowledgements

• [X] I may be able to implement this feature request
• [ ] This feature might incur a breaking change

Language

Python