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)