[ https://issues.apache.org/jira/browse/KAFKA-9376?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17038934#comment-17038934 ]
candan commented on KAFKA-9376: ------------------------------- Hello; We also encountred the same problem? Did you find any clue. > 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)