我运行的是mirror maker 2.0（来自kafka 2.6的二进制文件），我的源集群是用纯文本配置的，而我的目标集群是用ssl启用的
我已经创建了正确的密钥，并确保第一个连接在下面的命令下正常工作，

./kafka-topics.sh --list topics --bootstrap-server my-target:9092 --command-config ssl_properties

ssl\u属性文件如下所示，
security.protocol=ssl协议
ssl.truststore.location=/opt/keys/client.truststore
ssl.truststore.password=123456
ssl.keystore.location=/opt/keys/jacek.keystore
ssl.keystore.password=123456 ssl.key.password=密码
现在，当我尝试运行mirror maker时，它失败了，出现以下错误，mirror maker配置文件中的配置类似于下面的配置，

> source.security.protocol=PLAINTEXT target.security.protocol=SSL
> target.ssl.truststore.location=/opt/kafka/poc-config/keys/client.truststore
> target.ssl.truststore.password=123456
> target.ssl.keystore.location=/opt/kafka/poc-config/keys/jacek.keystore
> target.ssl.keystore.password=123456 target.ssl.key.password=password

错误：
org.apache.kafka.common.errors.timeoutexception:调用（callname=fetchmetadata，deadlinems=1605011994642，tries=1，nextallowedtryms=1605011994743）在1次尝试后在1605011994643超时，原因是：org.apache.kafka.common.errors.timeoutexception:等待节点分配时超时。调用：fetchmetadata[2020-11-10 12:40:24642]info app info kafka.admin.client for adminclient-8 unregistered（org.apache.kafka.common.utils.appinfoparser:83) [2020-11-10 12:40:24,643]信息[adminclient clientid=adminclient-8]元数据更新失败（org.apache.kafka.clients.admin.internals.adminmetada）tamanager:235)org.apache.kafka.common.errors.timeoutexception:调用（callname=fetchmetadata，deadlinems=1605012024643，tries=1，nextallowedtryms=-9223372036854775709）在9223372036854775807超时，原因是：org.apache.kafka.common.errors.timeoutexception:adminclient线程已退出。调用：fetchmetadata[2020-11-10 12:40:24644]info metrics scheduler closed（org.apache.kafka.common.metrics）。metrics:668)[2020-11-10 12:40:24644]信息关闭报告器org.apache.kafka.common.metrics.jmxreporter（org.apache.kafka.common.metrics）。metrics:672) [2020-11-10 12:40:24,644]InfoMetrics reporters关闭（org.apache.kafka.common.metrics）。metrics:678)[2020-11-10 12:40:24645]错误导致错误停止（org.apache.kafka.connect.mirror.mirrormaker:304)org.apache.kafka.connect.errors.connectexception:未能连接到并描述kafka群集。检查工作者的代理连接和安全属性。在org.apache.kafka.connect.util.connectutils.lookupkafkaclusterid（connectutils。java:70)在org.apache.kafka.connect.util.connectutils.lookupkafkaclusterid（connectutils。java:51)在org.apache.kafka.connect.mirror.mirrormaker.addherder（mirrormaker。java:235)在org.apache.kafka.connect.mirror.mirrormaker.lambda$new$1（mirrormaker。java:136)在java.lang.iterable.foreach（iterable。java:75)在org.apache.kafka.connect.mirror.mirrormaker。java:136)在org.apache.kafka.connect.mirror.mirrormaker。java:148)在org.apache.kafka.connect.mirror.mirrormaker.main（mirrormaker。java:291)原因：java.util.concurrent.executionexception：org.apache.kafka.common.errors.timeoutexception:调用（callname=listnodes，deadlinems=1605012024641，tries=1，nextallowedtryms=1605012024742）在org.apache.kafka.common.internals.kafkafutureinpl.wrapandthrow（kafkafutureinpl）上尝试1次后，在1605012024642处超时。java:45)访问org.apache.kafka.common.internals.kafkafutureinpl.access$000（kafkafutureinpl。java:32)在org.apache.kafka.common.internals.kafkafutureinpl$singlewaiter.await（kafkafutureinpl。java:89)在org.apache.kafka.common.internals.kafkafutureinpl.get（kafkafutureinpl。java:260)在org.apache.kafka.connect.util.connectutils.lookupkafkaclusterid（connectutils。java:64) ... 7其他原因：org.apache.kafka.common.errors.timeoutexception:call（callname=listnodes，deadlinems=1605012024641，tries=1，nextallowedtryms=1605012024742）在1605012024642处超时，原因是：org.apache.kafka.common.errors.timeoutexception:timeout等待节点分配时超时。调用：listnodes