我很确定 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);
出现错误,引导服务器中没有给出可解析的引导网址,
[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
“metadata.broker.list”已弃用,并使用“bootstrap.servers”。从代码中删除“metadata.broker.list”配置应该可以解决问题。请在bootstrap.servers和metadata.broker.list之间的差异
找到更多详细信息就我而言,bootstrap.servers 不是主机:端口格式
就我而言,只是公司 VPN 已关闭并且无法访问服务器
对于任何在 MapR 客户端库中遇到此问题的人,如果您忘记了流名称前面的 /,您将会遇到此问题。
我在不同的容器中使用kafka客户端运行kafka代理和myapp,在我的例子中,当使用我的应用程序运行容器时,我没有添加参数
network
。
docker run -it --rm --network example_network my_repo/my_image:my_tag
必须在代理容器中指定
network (example_network)
。
此错误可能表明存在网络连接问题。例如,如果服务器主机未知(没有关联 IP),则会触发。
就我而言,在 application.properties 中有一个属性“spring.profiles.active”默认设置为“stage”,将其更改为“local”解决了我的错误
spring.profiles.active = stage -> local