Sample code that shows the important aspects of developing custom connectors for Kafka Connect. It provides the resources for building, deploying, and running the code on-premises using Docker, as well as running the code in the cloud.

Technical solution to implement event processing prioritization with Apache Kafke using the concept of buckets.

Data Pipeline for CDC data from MySQL DB to Amazon S3 through Amazon MSK using Amazon MSK Connect (Debezium).

The CloudFormation Resource Provider Package For Amazon MSK Connect

AWS Secrets Manager Config Provider for Apache Kafka