Greg Harris created KAFKA-15291:
-----------------------------------
Summary: Implemented Versioned interfaces in common Connect plugins
Key: KAFKA-15291
URL: https://issues.apache.org/jira/browse/KAFKA-15291
Project: Kafka
Issue Type: Improvement
Components: KafkaConnect
Reporter: Greg Harris
Fix For: 3.6.0
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.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
