Sinóros-Szabó Péter created KAFKA-9376: ------------------------------------------
Summary: 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 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)