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

首页课程实战体系课手记专栏慕课教程

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

来源：4-3 kafka代码案例

慕粉3216583

2020-05-28 10:02

我们运维在服务器参考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)