What's New

Updated the connector behavior to explicitly target v1.3 as the preferred secure protocol and fallback to v1.2 if v1.3 is unavailable. The getSecureSslContext() method now returns an SSLContext configured with v1.3 or v1.2, and throws NoSuchAlgorithmException if neither is available.

Changed log message from WARN level to ERROR when the connector fails to resume a change stream. Such errors are now reflected in failure metrics.

Upgraded the Apache Kafka dependency to address security vulnerabilities.

Added the DeleteOneTombstoneBusinessKeyStrategy to change stream sink connector configuration.

Added change.stream.show.expanded.events change stream source connector configuration.

Fixed an issue introduced in Apache Kafka version 3.9 around the Kafka SystemTime class.

Added support for removing all null valued fields in the output with the NullFieldValueRemover prebuilt post processor. To learn more, see Prebuilt Post Processors.

Fixed a bug where data copies itself again when a task restarts. To learn more about this fix, see the KAFKA-428 JIRA issue.

Added a custom authentication provider interface for Source and Sink Connectors. This feature enables you to write and use a custom implementation class in your connector. To learn more, see the Custom Authentication Provider guide.

Fixed an issue that occurred when validating configuration for Source and Sink Connectors if the configuration contained secrets and used the Provider framework. To learn more about this fix, see the KAFKA-414 JIRA issue.

Added support for a data configuration value in the mongo.errors.tolerance configuration setting. With mongo.errors.tolerance=data, the sink connector tolerates only data errors, and fails for any others.