[
https://issues.apache.org/jira/browse/KAFKA-8415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Randall Hauch resolved KAFKA-8415.
----------------------------------
Resolution: Fixed
Reviewer: Randall Hauch
Merged onto the `trunk` and `2.3` branches.
> Interface ConnectorClientConfigOverridePolicy needs to be excluded from class
> loading isolation
> -----------------------------------------------------------------------------------------------
>
> Key: KAFKA-8415
> URL: https://issues.apache.org/jira/browse/KAFKA-8415
> Project: Kafka
> Issue Type: Bug
> Components: KafkaConnect
> Affects Versions: 2.3.0
> Reporter: Konstantine Karantasis
> Assignee: Konstantine Karantasis
> Priority: Blocker
> Fix For: 2.3.0
>
>
> Classes or interfaces that implement {{ConnectorClientConfigOverridePolicy}}
> were recently added in Connect as plugins that can be loaded in class loading
> isolation.
> However the interface itself was not excluded from isolation itself, which
> results into definition conflicts. Any interface that is considered a base
> Connect plugin interface needs to be excluded by isolation itself (it's
> considered a "system" type).
> Here's the exception:
> {code:java}
> [2019-05-23 15:16:57,802] ERROR Stopping due to error
> (org.apache.kafka.connect.cli.ConnectDistributed:84)
> java.util.ServiceConfigurationError:
> org.apache.kafka.connect.connector.policy.ConnectorClientConfigOverridePolicy:
> Provider
> org.apache.kafka.connect.connector.policy.AllConnectorClientConfigOverridePolicy
> not a subtype
> at java.util.ServiceLoader.fail(ServiceLoader.java:239)
> at java.util.ServiceLoader.access$300(ServiceLoader.java:185)
> at java.util.ServiceLoader$LazyIterator.nextService(ServiceLoader.java:376)
> at java.util.ServiceLoader$LazyIterator.next(ServiceLoader.java:404)
> at java.util.ServiceLoader$1.next(ServiceLoader.java:480)
> at
> org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.getServiceLoaderPluginDesc(DelegatingClassLoader.java:343)
> at
> org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanPluginPath(DelegatingClassLoader.java:317)
> at
> org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.scanUrlsAndAddPlugins(DelegatingClassLoader.java:244)
> at
> org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.registerPlugin(DelegatingClassLoader.java:236)
> at
> org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initPluginLoader(DelegatingClassLoader.java:205)
> at
> org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader.initLoaders(DelegatingClassLoader.java:182)
> at org.apache.kafka.connect.runtime.isolation.Plugins.<init>(Plugins.java:61)
> at
> org.apache.kafka.connect.cli.ConnectDistributed.startConnect(ConnectDistributed.java:91)
> at
> org.apache.kafka.connect.cli.ConnectDistributed.main(ConnectDistributed.java:78)
> {code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
