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

MirrorSourceConnector don`t work on connect-distributed.sh

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Open
    • Major
    • Resolution: Unresolved
    • 2.4.1
    • 2.4.1
    • mirrormaker
    • None
    • centos7

    Description

      hi
      I want to run a MirrorSourceConnector with connect-distributed .
      the connector config like this :
      ```
      {
      "name" : "cosmo-source",
      "config" :

      { "connector.class" : "org.apache.kafka.connect.mirror.MirrorSourceConnector", "source.cluster.alias" : "cosmo", "target.cluster.alias" : "nana", "source.cluster.bootstrap.servers" : "192.168.4.42:9092,192.168.4.42:9093,192.168.4.42:9094", "topics" : ".*" }

      }
      ```

      when I post the rest requestion, it returns to me
      ```
      {"name":"cosmo-source","config":

      {"connector.class":"org.apache.kafka.connect.mirror.MirrorSourceConnector","target.cluster.alias":"nana","topics":".*","source.cluster.alias":"cosmo","name":"cosmo-source","source.cluster.bootstrap.servers":"192.168.4.42:9092,192.168.4.42:9093,192.168.4.42:9094"}

      ,"tasks":[],"type":"source"}
      ```
      the task array is empty.

      It's obvious that something's wrong here.

      in connectDistributed.out
      ```
      org.apache.kafka.common.config.ConfigException: Missing required configuration "bootstrap.servers" which has no default value.
      ```

      full logs in the attachment.

      thanks for any help.

       

      Attachments

        1. connectDistributed.out
          199 kB
          cosmozhu

        Activity

          People

            Unassigned Unassigned
            cosmozhu cosmozhu
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated: