You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Rens Groothuijsen (Jira)" <ji...@apache.org> on 2020/07/26 23:14:00 UTC
[jira] [Commented] (KAFKA-10159) MirrorSourceConnector don`t work
on connect-distributed.sh
[ https://issues.apache.org/jira/browse/KAFKA-10159?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17165362#comment-17165362 ]
Rens Groothuijsen commented on KAFKA-10159:
-------------------------------------------
[~ryannedolan] From what I can see, MirrorConnectorConfig does try to include fields from AdminClientConfig (which holds the required bootstrap.servers parameter) but does not validate it as part of its own config definition. I suppose an error would have to be thrown manually if any extra parameters outside the config definition are missing.
> 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
> Priority: Major
> 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)