You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "cosmozhu (Jira)" <ji...@apache.org> on 2020/06/15 03:49:00 UTC

[jira] [Created] (KAFKA-10159) MirrorSourceConnector don`t work on connect-distributed.sh

cosmozhu created KAFKA-10159:
--------------------------------

             Summary: MirrorSourceConnector don`t work on connect-distributed.sh
                 Key: KAFKA-10159
                 URL: https://issues.apache.org/jira/browse/KAFKA-10159
             Project: Kafka
          Issue Type: Bug
          Components: mirrormaker
    Affects Versions: 2.4.1
         Environment: centos7
            Reporter: cosmozhu
             Fix For: 2.4.1
         Attachments: connectDistributed.out

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.


 



--
This message was sent by Atlassian Jira
(v8.3.4#803005)