[KAFKA-15291] Implement Versioned interfaces in common Connect plugins

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 3.6.0
• Component/s: connect
• Assignee: Aindriú Lavelle
• Reporter: Greg Harris
• Created: 01/Aug/23 21:36
• Updated: 10/Aug/23 17:45
• Resolved: 10/Aug/23 17:45

Description

In KAFKA-14863, we changed the plugin scanning logic to allow plugins to opt-in to the Versioned interface individually, when previously it was limited to Connector plugins.

To take advantage of this change, we should have all of the plugins built via the Kafka repository opt-in, and provide the environment's Kafka version from the AppInfoParser.getVersion().

See the FileStreamSinkConnector as an example of the the version() method implementation.

All subclasses of Converter, HeaderConverter, Transformation, Predicate, and ConnectorClientConfigOverridePolicy should implement Versioned. The interfaces themselves will not extend Versioned, as that would be a backwards-incompatible change.

Issue Links

• relates to: KAFKA-14863 Plugins which do not have a valid no-args constructor are visible in the REST API