2016-11-16 12 views
6

में दिए गए कोई भी हल करने योग्य बूटस्ट्रैप यूआरएल मुझे यकीन है कि bootstrap.servers सही है। क्या मेवेन में कुछ कड़वाहट है या कफका के साथ क्या गलत है ??कफका त्रुटि प्राप्त करना बूटस्ट्रैप सर्वर

इससे पहले कि यह सफलतापूर्वक काम कर रहा था। मैंने कुछ मेवेन या स्पार्क जोड़ा तो कुछ गलत हो गया ..

क्या कोई इसे हल करने के बारे में जानता है?

यहाँ, जावा

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 
+0

पर अधिक जानकारी प्राप्त करें क्या आपने सर्वर नाम के बजाय आईपी का उपयोग करने का प्रयास किया है? शायद यह एक नाम संकल्प मुद्दा है –

उत्तर

3

"metadata.broker.list" पदावनत और "bootstrap.servers" है इसके बजाए प्रयोग किया जाता है। आपके कोड से "metadata.broker.list" कॉन्फ़िगरेशन को हटाने से समस्या हल होनी चाहिए। कृपया difference between bootstrap.servers and metadata.broker.list

संबंधित मुद्दे