问题描述
我正在运行mirror maker 2.0（来自kafka 2.6的二进制文件），并且我的源群集配置有纯文本，其中使用ssl启用了我的目标群集
我已经创建了正确的密钥，并使用以下命令确保第一个连接正常工作
./kafka-topics.sh --list topics --bootstrap-server my-target:9092 --command-config ssl_properties
ssl_properties文件如下，
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 =密码
现在，当我尝试运行镜像制作器时，由于以下错误而失败，并且镜像制作器配置文件中的配置类似，如下所示，
> 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，最后期限Ms = 1605011994642，try = 1，nextAllowedTryMs = 1605011994743）1次尝试后在1605011994643超时 引起原因：org.apache.kafka.common.errors.TimeoutException：等待节点分配超时。呼叫：fetchMetadata [2020-11-10 12：40：24,642]信息应用程序信息kafka.admin.client未注册adminclient-8（org.apache.kafka.common.utils.AppInfoParser：83） [2020-11-10 12：40：24,643]信息[AdminClient clientId = adminclient-8]元数据更新失败（org.apache.kafka.clients.admin.internals.AdminMetadataManager：235） org.apache.kafka.common.errors.TimeoutException：Call（callName = fetchMetadata，最后期限Ms = 1605012024643，try = 1，nextAllowedTryMs = -9223372036854775709）1次尝试后在9223372036854775807超时 由以下原因引起：org.apache.kafka.common.errors.TimeoutException：AdminClient线程已退出。呼叫：fetchMetadata [2020-11-10 12：40：24,644]信息Metrics调度程序已关闭（org.apache.kafka.common.metrics.Metrics：668） [2020-11-10 12：40：24,644]信息正在关闭记者org.apache.kafka.common.metrics.JmxReporter（org.apache.kafka.common.metrics.Metrics：672） [2020-11-10 12：40：24,644] INFO Metrics记者已关闭（org.apache.kafka.common.metrics.Metrics：678） [2020-11-10 12：40：24,645]错误由于错误而停止（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。（MirrorMaker.java:136） 在org.apache.kafka.connect.mirror.MirrorMaker。（MirrorMaker.java:148） 在org.apache.kafka.connect.mirror.MirrorMaker.main（MirrorMaker.java:291） 由以下原因引起：java.util.concurrent.ExecutionException：org.apache.kafka.common.errors.TimeoutException：Call（callName = listNodes，durationMs = 1605012024641，trys = 1，nextAllowedTryMs = 1605012024742）在1次尝试后在1605012024642超时） 在org.apache.kafka.common.internals.KafkaFutureImpl.wrapAndThrow（KafkaFutureImpl.java:45） 在org.apache.kafka.common.internals.KafkaFutureImpl.access $ 000（KafkaFutureImpl.java:32） 在org.apache.kafka.common.internals.KafkaFutureImpl $ SingleWaiter.await（KafkaFutureImpl.java:89） 在org.apache.kafka.common.internals.KafkaFutureImpl.get（KafkaFutureImpl.java:260） 在org.apache.kafka.connect.util.ConnectUtils.lookupKafkaClusterId（ConnectUtils.java:64） ...另外7个 由以下原因引起：org.apache.kafka.common.errors.TimeoutException：Call（callName = listNodes，durationMs = 1605012024641，try = 1，nextAllowedTryMs = 1605012024742）1次尝试后在1605012024642超时 引起原因：org.apache.kafka.common.errors.TimeoutException：等待节点分配超时。呼叫：listNodes
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）