                        课程
                    
                        /后端开发
                        
                            /Java
                        
                        /Kafka流处理平台

日志显示超时并且命令行的消费端没有输出

我们运维在服务器参考kafka官方文档安装了kafka 然后我在命令行尝试了生产和消费都是正常的然后我新建了一个topic

然后我把这个课程的代码下载下来然后修改配置文件里面的生产者和消费者指向的服务器的ip地址以及topic

然后我把工程启动起来

然后使用postman发送

登录半天输出

{

"code": 200,

"message": "发送kafka成功"

}

然后IDEA 的日志输出

org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

2020-05-28 09:59:53.584 INFO 13735 --- [nio-8080-exec-3] c.i.kafka.controller.ProduceController : 发送kafka成功.

org.springframework.kafka.core.KafkaProducerException: Failed to send; nested exception is org.apache.kafka.common.errors.TimeoutException: Failed to update metadata after 60000 ms.

at org.springframework.kafka.core.KafkaTemplate$1.onCompletion(KafkaTemplate.java:364)

at org.apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:827)

at org.apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:768)

at org.springframework.kafka.core.DefaultKafkaProducerFactory$CloseSafeProducer.send(DefaultKafkaProducerFactory.java:285)

at org.springframework.kafka.core.KafkaTemplate.doSend(KafkaTemplate.java:349)

at org.springframework.kafka.core.KafkaTemplate.send(KafkaTemplate.java:206)

at com.imooc.kafka.producer.SimpleProducer.send(SimpleProducer.java:32)

at com.imooc.kafka.controller.ProduceController.sendKafka(ProduceController.java:40)

at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)

at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)

at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)

at java.lang.reflect.Method.invoke(Method.java:498)

at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:209)

at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:136)

at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:102)

at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:877)

at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:783)

at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)

at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:991)

at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:925)

at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:974)

at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:877)

at javax.servlet.http.HttpServlet.service(HttpServlet.java:661)

at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:851)

at javax.servlet.http.HttpServlet.service(HttpServlet.java:742)

at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)