What's New

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.