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

MirrorSourceConnector don`t work on connect-distributed.sh

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Open
    • Priority: Major
    • Resolution: Unresolved
    • Affects Version/s: 2.4.1
    • Fix Version/s: 2.4.1
    • Component/s: mirrormaker
    • Labels:
      None
    • Environment:
      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

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              cosmozhu cosmozhu

              Dates

              • Created:
                Updated:

                Issue deployment