Kafka Erreur d'obtention Aucune adresse d'amorçage résolvable donnée dans les serveurs d'amorçage

Question

Je suis assez sûr que le bootstrap.servers est correct. Y a-t-il quelque chose de conflictuel dans Maven ou quoi de mauvais avec Kafka ??

Avant cela Il fonctionnait avec succès. J'ai ajouté du Maven ou du Spark puis quelque chose s'est mal passé.

Quelqu'un peut-il savoir comment le résoudre?

Voici kafka code java

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); 

Obtenir erreur Aucun urls bootstrap résoluble données dans les serveurs d'amorçage,

[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 

Answer 1

"metadata.broker.list" est dépréciée et "bootstrap.servers" est utilisé à la place. Supprimer la configuration "metadata.broker.list" de votre code devrait résoudre le problème. S'il vous plaît trouver plus de détails à difference between bootstrap.servers and metadata.broker.list