[
https://issues.apache.org/jira/browse/KAFKA-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17013391#comment-17013391
]
yzhou commented on KAFKA-9376:
------------------------------
[~ryannedolan]
Here is a portion of the startup log:
[ org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:264 ] - [
INFO ] Registered loader: sun.misc.Launcher$AppClassLoader@18b4aac2
[ org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193 ] - [
INFO ] Added plugin 'org.apache.kafka.connect.tools.MockConnector'
[ org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193 ] - [
INFO ] Added plugin 'org.apache.kafka.connect.tools.SchemaSourceConnector'
[ org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193 ] - [
INFO ] Added plugin 'org.apache.kafka.connect.mirror.MirrorSourceConnector'
[ org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193 ] - [
INFO ] Added plugin 'org.apache.kafka.connect.tools.VerifiableSinkConnector'
[ org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193 ] - [
INFO ] Added plugin 'org.apache.kafka.connect.mirror.MirrorCheckpointConnector'
[ org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193 ] - [
INFO ] Added plugin 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector'
[ org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193 ] - [
INFO ] Added plugin 'org.apache.kafka.connect.tools.VerifiableSourceConnector'
[ org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193 ] - [
INFO ] Added plugin 'org.apache.kafka.connect.tools.MockSourceConnector'
[ org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193 ] - [
INFO ] Added plugin 'org.apache.kafka.connect.tools.MockSinkConnector'
[ org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:193 ] - [
INFO ] Added plugin 'org.apache.kafka.connect.converters.LongConverter'
MirrorCheckpointConnector,MirrorHeartbeatConnector,MirrorSourceConnector loaded
by AppCliassLoader(getParent()) ， but they should be loaded by pluginLoader
independently (PluginUtils.shouldLoadInIsolation(name))
> Plugin class loader not found using MM2
> ---------------------------------------
>
> Key: KAFKA-9376
> URL: https://issues.apache.org/jira/browse/KAFKA-9376
> Project: Kafka
> Issue Type: Bug
> Components: mirrormaker
> Affects Versions: 2.4.0
> Reporter: Sinóros-Szabó Péter
> Priority: Minor
>
> I am using MM2 (release 2.4.0 with scala 2.12) I geta bunch of classloader
> errors. MM2 seems to be working, but I do not know if all of it components
> are working as expected as this is the first time I use MM2.
> I run MM2 with the following command:
> {code:java}
> ./bin/connect-mirror-maker.sh config/connect-mirror-maker.properties
> {code}
> Errors are:
> {code:java}
> [2020-01-07 15:06:17,892] ERROR Plugin class loader for connector:
> 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found.
> Returning:
> org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@6ebf0f36
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165)
> [2020-01-07 15:06:17,889] ERROR Plugin class loader for connector:
> 'org.apache.kafka.connect.mirror.MirrorHeartbeatConnector' was not found.
> Returning:
> org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader@6ebf0f36
> (org.apache.kafka.connect.runtime.isolation.DelegatingClassLoader:165)
> [2020-01-07 15:06:17,904] INFO ConnectorConfig values:
> config.action.reload = restart
> connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector
> errors.log.enable = false
> errors.log.include.messages = false
> errors.retry.delay.max.ms = 60000
> errors.retry.timeout = 0
> errors.tolerance = none
> header.converter = null
> key.converter = null
> name = MirrorHeartbeatConnector
> tasks.max = 1
> transforms = []
> value.converter = null
> (org.apache.kafka.connect.runtime.ConnectorConfig:347)
> [2020-01-07 15:06:17,904] INFO EnrichedConnectorConfig values:
> config.action.reload = restart
> connector.class = org.apache.kafka.connect.mirror.MirrorHeartbeatConnector
> errors.log.enable = false
> errors.log.include.messages = false
> errors.retry.delay.max.ms = 60000
> errors.retry.timeout = 0
> errors.tolerance = none
> header.converter = null
> key.converter = null
> name = MirrorHeartbeatConnector
> tasks.max = 1
> transforms = []
> value.converter = null
>
> (org.apache.kafka.connect.runtime.ConnectorConfig$EnrichedConnectorConfig:347)
> [2020-01-07 15:06:17,905] INFO TaskConfig values:
> task.class = class org.apache.kafka.connect.mirror.MirrorHeartbeatTask
> (org.apache.kafka.connect.runtime.TaskConfig:347)
> [2020-01-07 15:06:17,905] INFO Instantiated task MirrorHeartbeatConnector-0
> with version 1 of type org.apache.kafka.connect.mirror.MirrorHeartbeatTask
> (org.apache.kafka.connect.runtime.Worker:434){code}
> After a while, these errors are not logged any more.
> Config is:
> {code:java}
> clusters = eucmain, euwbackup
> eucmain.bootstrap.servers = kafka1:9092,kafka2:9092
> euwbackup.bootstrap.servers = 172.30.197.203:9092,172.30.213.104:9092
> eucmain->euwbackup.enabled = true
> eucmain->euwbackup.topics = .*
> eucmain->euwbackup.topics.blacklist = ^(kafka|kmf|__|pricing).*
> eucmain->euwbackup.rename.topics = false
> rename.topics = false
> eucmain->euwbackup.sync.topic.acls.enabled = false
> sync.topic.acls.enabled = false{code}
> Using OpenJDK 8 or 11, I get the same error.
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
