Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-9376

Plugin class loader not found using MM2

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Minor
    • Resolution: Unresolved
    • Affects Version/s: 2.4.0
    • Fix Version/s: None
    • Component/s: mirrormaker
    • Labels:
      None

      Description

      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:

      ./bin/connect-mirror-maker.sh config/connect-mirror-maker.properties
      

      Errors are:

      [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)

      After a while, these errors are not logged any more.

      Config is:

      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

      Using OpenJDK 8 or 11, I get the same error.

       

        Attachments

          Issue Links

            Activity

              People

              • Assignee:
                Unassigned
                Reporter:
                sini Sinóros-Szabó Péter
              • Votes:
                2 Vote for this issue
                Watchers:
                8 Start watching this issue

                Dates

                • Created:
                  Updated: