A Kotlin port of the kafka-connect-dynamodb project which implements a source connector for AWS DynamoDB Streams. This connector allows for effortless replication of data from DynamoDB tables into Kafka topics with strong consistency guarantees, which is especially useful when building data pipelines or implementing transactional outboxes to support asynchronous inter-service communication.
This was done as a way to practice Kotlin. This connector is missing test coverage, proper logging, and has not been
tested at any meaningful scale. Please use the kafka-connect-dynamodb project linked above.