问题 Kafka Mirror Maker 从 1.0.2 更新到 2.2.0 - 构建消费者失败 - 没有可解析的 bootstrap url
Issue Kafka Mirror Maker updated from 1.0.2 to 2.2.0 - Failed to construct consumer - No resolvable bootstrap urls
最近我更新了 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 镜像时,现在是 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 镜像制造商的东西?唯一不同的是 kafka 我从 1.0.0 升级到 2.2.0 - 其他一切都保持不变。
移动评论以回答...
该错误似乎表明您错误配置了 consumer.properties
文件中的 bootstrap.servers
属性。
不应在您提到的任何 Kafka 版本上使用 Zookeeper 作为单独的连接字符串。
最近我更新了 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 镜像时,现在是 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 镜像制造商的东西?唯一不同的是 kafka 我从 1.0.0 升级到 2.2.0 - 其他一切都保持不变。
移动评论以回答...
该错误似乎表明您错误配置了 consumer.properties
文件中的 bootstrap.servers
属性。
不应在您提到的任何 Kafka 版本上使用 Zookeeper 作为单独的连接字符串。