Kafka 出现错误在引导服务器中没有给出可解析的引导 URL

Posted 2023-03-10

【中文标题】Kafka 出现错误在引导服务器中没有给出可解析的引导 URL

【英文标题】：Kafka Getting error No resolvable bootstrap urls given in bootstrap servers

【发布时间】：2017-03-30 16:43:18

【问题描述】：

我很确定 bootstrap.servers 是正确的。 Maven有什么冲突或者Kafka有什么问题吗？？

在此之前它工作成功。我添加了一些 Maven 或 Spark，然后出了点问题..

谁能知道怎么解决？

这是java中的kafka代码

Properties props = new Properties();
        props.put("bootstrap.servers", "x.xx.xxx.xxx:9092");
        props.put("metadata.broker.list", "x.xx.xxx.xxx:9091, x.xx.xxx.xxx:9092, x.xx.xxx.xxx:9093");

        props.put("producer.type", "async");
        props.put("batch.size", "500");
        props.put("compression.codec", "1");
        props.put("compression.topic", topicName);
        props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");
        props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

            org.apache.kafka.clients.producer.Producer<String, String> producer = new KafkaProducer<String, String>(
                    props);

得到错误没有在引导服务器中给出可解析的引导 URL，

[err]   at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:335)
    [err]   at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:188)
    [err]   at com.wra.controller.ParserController.GetResumeUpload(ParserController.java:98)
    [err]   at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    [err]   at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:95)
    [err]   at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:55)
    [err]   at java.lang.reflect.Method.invoke(Method.java:508)
    [err]   at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:221)
    [err]   at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:136)
    [err]   at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:114)
    [err]   at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827)
    [err]   at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738)
    [err]   at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85)
    [err]   at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:963)
    [err]   at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:897)
    [err]   at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:970)
    [err]   at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:872)
    [err]   at javax.servlet.http.HttpServlet.service(HttpServlet.java:707)
    [err]   at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:846)
    [err]   at javax.servlet.http.HttpServlet.service(HttpServlet.java:790)
    [err]   at com.ibm.ws.webcontainer.servlet.ServletWrapper.service(ServletWrapper.java:1290)
    [err]   at [internal classes]
    [err]   at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:52)
    [err]   at com.ibm.ws.webcontainer.filter.FilterInstanceWrapper.doFilter(FilterInstanceWrapper.java:207)
    [err]   at [internal classes]
    [err]   at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1153)
    [err]   at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
    [err]   at java.lang.Thread.run(Thread.java:785)
    [err] Caused by: 
    [err] org.apache.kafka.common.config.ConfigException: No resolvable bootstrap urls given in bootstrap.servers
    [err]   at org.apache.kafka.clients.ClientUtils.parseAndValidateAddresses(ClientUtils.java:59)
    [err]   at org.apache.kafka.clients.producer.KafkaProducer.<init>(KafkaProducer.java:275)
    [err]   ... 51 more

【问题讨论】：

你试过用IP代替服务器名吗？也许这是一个名称解析问题

@Vimal Dhaduk，你能解决这个问题吗？

【参考方案1】：

“metadata.broker.list”已被弃用，而使用“bootstrap.servers”。从代码中删除“metadata.broker.list”配置应该可以解决问题。更多详情请至difference between bootstrap.servers and metadata.broker.list

【参考方案2】：

对于遇到此 MapR 客户端库问题的任何人，如果您忘记了流名称前面的 /，您将得到此问题。

【参考方案3】：

在我的例子中，bootstrap.servers 不是 host:port 格式

【讨论】：

请添加更多详细信息以扩展您的答案，例如工作代码或文档引用。

感谢帮助，我还将 bootstrap.servers 配置为 127.0.0.1 而不是 127.0.0.1:9092。我添加了端口，现在它可以工作了。

【参考方案4】：

在我的情况下，只是公司 *** 已关闭并且无法访问服务器