CDC-to-Kafka 4.1.0
This release adds two new features:
- Snapshot logging: You can now configure the process to optionally produce to a new logging topic, with messages that provide a history of table snapshot start/completion/reset events. This is meant to support cleaning up prior messages in a table-topic if and when a later re-snapshot of a table is performed.
- IAM authentication for AWS MSK clusters: New configuration parameters allow for SASL/OAUTHBEARER-based authentication to AWS MSK Kafka clusters secured via IAM. The code structure also provides for an easy way to add other OAuth-based authenticators in the future.
The process is now based on Python 3.12, and Python package dependencies have been updated to the latest currently available.