1

我正在运行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,deadlineMs=1605011994642,trys=1,nextAllowedTryMs=1605011994743)在 1605011994643 1 次尝试后超时原因:org.apache.kafka.common .errors.TimeoutException:等待节点分配超时。调用:fetchMetadata [2020-11-10 12:40:24,642] INFO App info kafka.admin.client for adminclient-8 未注册(org.apache.kafka.common.utils.AppInfoParser:83)[2020-11-10 12 :40:24,643] INFO [AdminClient clientId=adminclient-8] 元数据更新失败 (org.apache.kafka.clients.admin.internals.AdminMetadataManager:235) org.apache.kafka.common.errors.TimeoutException: Call(callName= fetchMetadata,deadlineMs=1605012024643,trys=1,nextAllowedTryMs=-9223372036854775709)在 9223372036854775807 次尝试后超时 原因:org.apache.kafka.common.errors。TimeoutException:AdminClient 线程已退出。调用:fetchMetadata [2020-11-10 12:40:24,644] INFO Metrics scheduler closed (org.apache.kafka.common.metrics.Metrics:668) [2020-11-10 12:40:24,644] INFO Closing Reporter 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] ERROR 由于错误而停止(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:70) 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, deadlineMs=1605012024641, Trys=1, nextAllowedTryMs=1605012024742) 超时在 1605012024642 尝试 1 次后原因:org.apache.kafka.common.errors.TimeoutException:等待节点分配超时。调用:listNodes apache.kafka.common.errors.TimeoutException:调用(callName=listNodes,deadlineMs=1605012024641,trys=1,nextAllowedTryMs=1605012024742)在 1605012024642 1 次尝试后超时原因:org.apache.kafka.common.errors .TimeoutException:等待节点分配超时。调用:listNodes apache.kafka.common.errors.TimeoutException:调用(callName=listNodes,deadlineMs=1605012024641,trys=1,nextAllowedTryMs=1605012024742)在 1605012024642 1 次尝试后超时原因:org.apache.kafka.common.errors .TimeoutException:等待节点分配超时。调用:listNodes

4

0 回答 0