0

最近我更新了 kafka 镜像，现在它无法连接到源 zk 服务器 - 消费者失败。之前的版本基于 java:openjdk-8-jre、kafka_2.11-1.0.2.tgz 和 zookeeper:3.4.10。我将 kafka 更新为 kafka_2.12-2.2.0.tgz，保持相同的 3.4.10 zk 版本和 java:openjdk-8-jre。问题是当我启动 kafka mirror 时，现在是 2.2.0，我得到一个非常奇怪的错误：

org.apache.kafka.common.KafkaException: Failed to construct kafka consumer
Caused by: org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
        at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:90)
        at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:49)
        at org.apache.kafka.clients.consumer.KafkaConsumer.<init>(KafkaConsumer.java:721)
        ... 13 more

如果我将 kafka 镜像切换回旧的 docker 镜像 1.0.2 - 它可以工作。我尝试使用源动物园服务器的 IP 地址，同样的错误。有人可以帮我解决这个错误吗？有没有专门针对 2.2.0 镜像制造商的东西？唯一的区别是我从 1.0.0 升级到 2.2.0 的卡夫卡 - 其他一切都保持不变。

4

1 回答 1

0

移动评论以回答...

该错误似乎表明您错误地配置了文件中的bootstrap.servers属性。consumer.properties

不应在您提到的任何 Kafka 版本上仅使用 Zookeeper 作为连接字符串。

于 2019-05-21T23:03:11.007 回答