kafka发送消息失败Failed to update metadata after 10000
家电修理 2023-07-16 19:17www.caominkang.com电器维修
1、和其他部门联调kafka，每天凌晨从他们那接收前一天的接口的调用数据。他们kafka推送报错
java.util.concurrent.ExecutionException: .apache.kafka.mon.errors.TimeoutException: Topic ic:XXX not present in metadata after 10000 ms. at .apache.kafka.clients.producer.KafkaProducer$FutureFailure.2、一开始我以为是我的问题，自己发送了一条数据，是能消费到的。 3、那应该就是他们的问题，我仔细排查发现他们的报错信息中说ic不存在，应该是多写了个ic,(KafkaProducer.java:1261) at .apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:923) at .apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:846) at .apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:733) at XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX.test(HealthCheckController.java:98) at sun.reflect.NativeMethodAessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAessorImpl.invoke(NativeMethodAessorImpl.java:62) at sun.reflect.DelegatingMethodAessorImpl.invoke(DelegatingMethodAessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at .springframeork.eb.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205) at .springframeork.eb.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:133) at .springframeork.eb.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:97) at .springframeork.eb.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827) at .springframeork.eb.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738) at .springframeork.eb.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85) at .springframeork.eb.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:967) at .springframeork.eb.servlet.DispatcherServlet.doService(DispatcherServlet.java:901) at .springframeork.eb.servlet.frameorkServlet.processRequest(frameorkServlet.java:970) at .springframeork.eb.servlet.frameorkServlet.doGet(frameorkServlet.java:861) at javax.servlet.http.HttpServlet.service(HttpServlet.java:635) at .springframeork.eb.servlet.frameorkServlet.service(frameorkServlet.java:846) at javax.servlet.http.HttpServlet.service(HttpServlet.java:742) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .apache.tomcat.ebsocket.server.WsFilter.doFilter(WsFilter.java:52) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.boot.eb.filter.ApplicationContextHeaderFilter.doFilterInternal(ApplicationContextHeaderFilter.java:55) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:101) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.boot.actuate.trace.WebRequestTraceFilter.doFilterInternal(WebRequestTraceFilter.java:110) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .apache.shiro.eb.servlet.ProxiedFilterChain.doFilter(ProxiedFilterChain.java:61) at .apache.shiro.eb.servlet.AdviceFilter.executeChain(AdviceFilter.java:108) at .apache.shiro.eb.servlet.AdviceFilter.doFilterInternal(AdviceFilter.java:137) at .apache.shiro.eb.servlet.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:125) at .apache.shiro.eb.servlet.ProxiedFilterChain.doFilter(ProxiedFilterChain.java:66) at .apache.shiro.eb.servlet.AbstractShiroFilter.executeChain(AbstractShiroFilter.java:450) at .apache.shiro.eb.servlet.AbstractShiroFilter$1.call(AbstractShiroFilter.java:365) at .apache.shiro.subject.support.SubjectCallable.doCall(SubjectCallable.java:90) at .apache.shiro.subject.support.SubjectCallable.call(SubjectCallable.java:83) at .apache.shiro.subject.support.DelegatingSubject.execute(DelegatingSubject.java:387) at .apache.shiro.eb.servlet.AbstractShiroFilter.doFilterInternal(AbstractShiroFilter.java:362) at .apache.shiro.eb.servlet.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:125) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:317) at .springframeork.security.eb.aess.intercept.FilterSecurityInterceptor.invoke(FilterSecurityInterceptor.java:127) at .springframeork.security.eb.aess.intercept.FilterSecurityInterceptor.doFilter(FilterSecurityInterceptor.java:91) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.aess.ExceptionTranslationFilter.doFilter(ExceptionTranslationFilter.java:114) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.session.SessionManagementFilter.doFilter(SessionManagementFilter.java:137) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.authentication.AnonymousAuthenticationFilter.doFilter(AnonymousAuthenticationFilter.java:111) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.servletapi.SecurityContextHolderAareRequestFilter.doFilter(SecurityContextHolderAareRequestFilter.java:170) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.savedrequest.RequestCacheAareFilter.doFilter(RequestCacheAareFilter.java:63) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX.doFilterInternal(JtAuthenticationTokenFilter.java:61) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.authentication.logout.LogoutFilter.doFilter(LogoutFilter.java:116) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.header.HeaderWriterFilter.doFilterInternal(HeaderWriterFilter.java:64) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.context.SecurityContextPersistenceFilter.doFilter(SecurityContextPersistenceFilter.java:105) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.context.request.async.WebAsyncManagerIntegrationFilter.doFilterInternal(WebAsyncManagerIntegrationFilter.java:56) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.FilterChainProxy.doFilterInternal(FilterChainProxy.java:214) at .springframeork.security.eb.FilterChainProxy.doFilter(FilterChainProxy.java:177) at .springframeork.eb.filter.DelegatingFilterProxy.invokeDelegate(DelegatingFilterProxy.java:347) at .springframeork.eb.filter.DelegatingFilterProxy.doFilter(DelegatingFilterProxy.java:263) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.eb.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:197) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.boot.actuate.autoconfigure.MetricsFilter.doFilterInternal(MetricsFilter.java:106) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:199) at .apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96) at .apache.catalina.authenticator.Authenticatorbase.invoke(Authenticatorbase.java:478) at .apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:140) at .apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:81) at .apache.catalina.core.StandardEnginevalve.invoke(StandardEnginevalve.java:87) at .apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:342) at .apache.coyote.http11.Http11Processor.service(Http11Processor.java:803) at .apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66) at .apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:868) at .apache.tomcat.util..NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1459) at .apache.tomcat.util..SocketProcessorbase.run(SocketProcessorbase.java:49) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at .apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(Thread.java:748) Caused by: .apache.kafka.mon.errors.TimeoutException: Topic ic:XXX not present in metadata after 10000 ms.
java.util.concurrent.ExecutionException: .apache.kafka.mon.errors.TimeoutException: Topic ic:XXX not present in metadata after 10000 ms.4、让他们截图，确实是这样的 ，心多大
5、去掉之后还是报错，奶奶的
java.util.concurrent.ExecutionException: .apache.kafka.mon.errors.TimeoutException: Topic XXX not present in metadata after 10000 ms. at .apache.kafka.clients.producer.KafkaProducer$FutureFailure.6、给我逼的没招了，把他们代码要过来我自己试一下，发送代码是这样的(KafkaProducer.java:1261) at .apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:923) at .apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:846) at .apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:733) at XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX.test(HealthCheckController.java:98) at sun.reflect.NativeMethodAessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAessorImpl.invoke(NativeMethodAessorImpl.java:62) at sun.reflect.DelegatingMethodAessorImpl.invoke(DelegatingMethodAessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at .springframeork.eb.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205) at .springframeork.eb.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:133) at .springframeork.eb.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:97) at .springframeork.eb.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827) at .springframeork.eb.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738) at .springframeork.eb.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85) at .springframeork.eb.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:967) at .springframeork.eb.servlet.DispatcherServlet.doService(DispatcherServlet.java:901) at .springframeork.eb.servlet.frameorkServlet.processRequest(frameorkServlet.java:970) at .springframeork.eb.servlet.frameorkServlet.doGet(frameorkServlet.java:861) at javax.servlet.http.HttpServlet.service(HttpServlet.java:635) at .springframeork.eb.servlet.frameorkServlet.service(frameorkServlet.java:846) at javax.servlet.http.HttpServlet.service(HttpServlet.java:742) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .apache.tomcat.ebsocket.server.WsFilter.doFilter(WsFilter.java:52) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.boot.eb.filter.ApplicationContextHeaderFilter.doFilterInternal(ApplicationContextHeaderFilter.java:55) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:101) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.boot.actuate.trace.WebRequestTraceFilter.doFilterInternal(WebRequestTraceFilter.java:110) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .apache.shiro.eb.servlet.ProxiedFilterChain.doFilter(ProxiedFilterChain.java:61) at .apache.shiro.eb.servlet.AdviceFilter.executeChain(AdviceFilter.java:108) at .apache.shiro.eb.servlet.AdviceFilter.doFilterInternal(AdviceFilter.java:137) at .apache.shiro.eb.servlet.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:125) at .apache.shiro.eb.servlet.ProxiedFilterChain.doFilter(ProxiedFilterChain.java:66) at .apache.shiro.eb.servlet.AbstractShiroFilter.executeChain(AbstractShiroFilter.java:450) at .apache.shiro.eb.servlet.AbstractShiroFilter$1.call(AbstractShiroFilter.java:365) at .apache.shiro.subject.support.SubjectCallable.doCall(SubjectCallable.java:90) at .apache.shiro.subject.support.SubjectCallable.call(SubjectCallable.java:83) at .apache.shiro.subject.support.DelegatingSubject.execute(DelegatingSubject.java:387) at .apache.shiro.eb.servlet.AbstractShiroFilter.doFilterInternal(AbstractShiroFilter.java:362) at .apache.shiro.eb.servlet.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:125) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:317) at .springframeork.security.eb.aess.intercept.FilterSecurityInterceptor.invoke(FilterSecurityInterceptor.java:127) at .springframeork.security.eb.aess.intercept.FilterSecurityInterceptor.doFilter(FilterSecurityInterceptor.java:91) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.aess.ExceptionTranslationFilter.doFilter(ExceptionTranslationFilter.java:114) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.session.SessionManagementFilter.doFilter(SessionManagementFilter.java:137) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.authentication.AnonymousAuthenticationFilter.doFilter(AnonymousAuthenticationFilter.java:111) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.servletapi.SecurityContextHolderAareRequestFilter.doFilter(SecurityContextHolderAareRequestFilter.java:170) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.savedrequest.RequestCacheAareFilter.doFilter(RequestCacheAareFilter.java:63) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX.doFilterInternal(JtAuthenticationTokenFilter.java:61) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.authentication.logout.LogoutFilter.doFilter(LogoutFilter.java:116) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.header.HeaderWriterFilter.doFilterInternal(HeaderWriterFilter.java:64) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.context.SecurityContextPersistenceFilter.doFilter(SecurityContextPersistenceFilter.java:105) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.context.request.async.WebAsyncManagerIntegrationFilter.doFilterInternal(WebAsyncManagerIntegrationFilter.java:56) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.FilterChainProxy.doFilterInternal(FilterChainProxy.java:214) at .springframeork.security.eb.FilterChainProxy.doFilter(FilterChainProxy.java:177) at .springframeork.eb.filter.DelegatingFilterProxy.invokeDelegate(DelegatingFilterProxy.java:347) at .springframeork.eb.filter.DelegatingFilterProxy.doFilter(DelegatingFilterProxy.java:263) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.eb.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:197) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.boot.actuate.autoconfigure.MetricsFilter.doFilterInternal(MetricsFilter.java:106) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:199) at .apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96) at .apache.catalina.authenticator.Authenticatorbase.invoke(Authenticatorbase.java:478) at .apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:140) at .apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:81) at .apache.catalina.core.StandardEnginevalve.invoke(StandardEnginevalve.java:87) at .apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:342) at .apache.coyote.http11.Http11Processor.service(Http11Processor.java:803) at .apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66) at .apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:868) at .apache.tomcat.util..NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1459) at .apache.tomcat.util..SocketProcessorbase.run(SocketProcessorbase.java:49) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at .apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(Thread.java:748) Caused by: .apache.kafka.mon.errors.TimeoutException: Topic XXX not present in metadata after 10000 ms.
Properties properties = ne Properties();
properties.put("bootstrap.servers", "......");
properties.put("key.serializer", ".apache.kafka.mon.serialization.StringSerializer");
properties.put("value.serializer", ".apache.kafka.mon.serialization.StringSerializer");
properties.put("security.protocol", "SASL_PLAINTEXT");
properties.put("sasl.mechanism", "SCRAM-SHA-256");
properties.put("max.block.ms", 10000);
properties.put("sasl.jaas.config", "......");
KafkaProducer producer = ne KafkaProducer(properties);
ProducerRecord record = ne ProducerRecord("icXXXXX", "{}");
try {
System.out.println("oout result:" + producer.send(record).get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
producer.close();
7、自己拿过来试一下，springboot集成的kafka组件的KafkaProducer是高度集成的。不能用Properties，没方法，找一个其他没用到Kafka组件的项目，引入kafka原始包
8、调用他们刚才的方法，确实报同样的错，挺邪门啊 9、我就换了个1.0.0的kafka，报错信息还变了.apache.kafka kafka_2.110.11.0.0
java.util.concurrent.ExecutionException: .apache.kafka.mon.errors.TimeoutException: Failed to update metadata after 10000 ms. at .apache.kafka.clients.producer.KafkaProducer$FutureFailure.10、报的是10秒内更新媒体文件超时，那我就搜一下超时相关的报错(KafkaProducer.java:1124) at .apache.kafka.clients.producer.KafkaProducer.doSend(KafkaProducer.java:823) at .apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:760) at .apache.kafka.clients.producer.KafkaProducer.send(KafkaProducer.java:648) at XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX.HealthCheckController.test(HealthCheckController.java:98) at sun.reflect.NativeMethodAessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAessorImpl.invoke(NativeMethodAessorImpl.java:62) at sun.reflect.DelegatingMethodAessorImpl.invoke(DelegatingMethodAessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at .springframeork.eb.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:205) at .springframeork.eb.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:133) at .springframeork.eb.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:97) at .springframeork.eb.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:827) at .springframeork.eb.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:738) at .springframeork.eb.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:85) at .springframeork.eb.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:967) at .springframeork.eb.servlet.DispatcherServlet.doService(DispatcherServlet.java:901) at .springframeork.eb.servlet.frameorkServlet.processRequest(frameorkServlet.java:970) at .springframeork.eb.servlet.frameorkServlet.doGet(frameorkServlet.java:861) at javax.servlet.http.HttpServlet.service(HttpServlet.java:635) at .springframeork.eb.servlet.frameorkServlet.service(frameorkServlet.java:846) at javax.servlet.http.HttpServlet.service(HttpServlet.java:742) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .apache.tomcat.ebsocket.server.WsFilter.doFilter(WsFilter.java:52) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.boot.eb.filter.ApplicationContextHeaderFilter.doFilterInternal(ApplicationContextHeaderFilter.java:55) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:101) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.boot.actuate.trace.WebRequestTraceFilter.doFilterInternal(WebRequestTraceFilter.java:110) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .apache.shiro.eb.servlet.ProxiedFilterChain.doFilter(ProxiedFilterChain.java:61) at .apache.shiro.eb.servlet.AdviceFilter.executeChain(AdviceFilter.java:108) at .apache.shiro.eb.servlet.AdviceFilter.doFilterInternal(AdviceFilter.java:137) at .apache.shiro.eb.servlet.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:125) at .apache.shiro.eb.servlet.ProxiedFilterChain.doFilter(ProxiedFilterChain.java:66) at .apache.shiro.eb.servlet.AbstractShiroFilter.executeChain(AbstractShiroFilter.java:450) at .apache.shiro.eb.servlet.AbstractShiroFilter$1.call(AbstractShiroFilter.java:365) at .apache.shiro.subject.support.SubjectCallable.doCall(SubjectCallable.java:90) at .apache.shiro.subject.support.SubjectCallable.call(SubjectCallable.java:83) at .apache.shiro.subject.support.DelegatingSubject.execute(DelegatingSubject.java:387) at .apache.shiro.eb.servlet.AbstractShiroFilter.doFilterInternal(AbstractShiroFilter.java:362) at .apache.shiro.eb.servlet.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:125) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:317) at .springframeork.security.eb.aess.intercept.FilterSecurityInterceptor.invoke(FilterSecurityInterceptor.java:127) at .springframeork.security.eb.aess.intercept.FilterSecurityInterceptor.doFilter(FilterSecurityInterceptor.java:91) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.aess.ExceptionTranslationFilter.doFilter(ExceptionTranslationFilter.java:114) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.session.SessionManagementFilter.doFilter(SessionManagementFilter.java:137) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.authentication.AnonymousAuthenticationFilter.doFilter(AnonymousAuthenticationFilter.java:111) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.servletapi.SecurityContextHolderAareRequestFilter.doFilter(SecurityContextHolderAareRequestFilter.java:170) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.savedrequest.RequestCacheAareFilter.doFilter(RequestCacheAareFilter.java:63) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX.doFilterInternal(JtAuthenticationTokenFilter.java:61) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.authentication.logout.LogoutFilter.doFilter(LogoutFilter.java:116) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.header.HeaderWriterFilter.doFilterInternal(HeaderWriterFilter.java:64) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.context.SecurityContextPersistenceFilter.doFilter(SecurityContextPersistenceFilter.java:105) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.context.request.async.WebAsyncManagerIntegrationFilter.doFilterInternal(WebAsyncManagerIntegrationFilter.java:56) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .springframeork.security.eb.FilterChainProxy$VirtualFilterChain.doFilter(FilterChainProxy.java:331) at .springframeork.security.eb.FilterChainProxy.doFilterInternal(FilterChainProxy.java:214) at .springframeork.security.eb.FilterChainProxy.doFilter(FilterChainProxy.java:177) at .springframeork.eb.filter.DelegatingFilterProxy.invokeDelegate(DelegatingFilterProxy.java:347) at .springframeork.eb.filter.DelegatingFilterProxy.doFilter(DelegatingFilterProxy.java:263) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.eb.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:197) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .springframeork.boot.actuate.autoconfigure.MetricsFilter.doFilterInternal(MetricsFilter.java:106) at .springframeork.eb.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107) at .apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193) at .apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166) at .apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:199) at .apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96) at .apache.catalina.authenticator.Authenticatorbase.invoke(Authenticatorbase.java:478) at .apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:140) at .apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:81) at .apache.catalina.core.StandardEnginevalve.invoke(StandardEnginevalve.java:87) at .apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:342) at .apache.coyote.http11.Http11Processor.service(Http11Processor.java:803) at .apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66) at .apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:868) at .apache.tomcat.util..NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1459) at .apache.tomcat.util..SocketProcessorbase.run(SocketProcessorbase.java:49) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at .apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61) at java.lang.Thread.run(Thread.java:748) Caused by: .apache.kafka.mon.errors.TimeoutException: Failed to update metadata after 10000 ms. 2022-03-14 17:12:51.041 INFO 25048 --- [nio-8081-exec-1] o.a.k.clients.producer.KafkaProducer : [Producer clientId=producer-1] Closing the Kafka producer ith timeoutMillis = 9223372036854775807 ms.
11、那个Properties里果然设置了这项，注释掉之后就好了。 12、还得靠我解决他们的问题，我可真是个天才。
空调维修
- 我的世界电脑版运行身份怎么弄出来（我的世界
- 空调抽湿是什么意思，设置抽湿的温度有什么意
- 方太燃气灶有一个打不着火 怎么修复与排查方法
- 夏季免费清洗汽车空调的宣传口号
- 清洗完空调后出现漏水现象
- iphone6能玩什么游戏（iphone6游戏）
- 如何设置电脑密码锁屏（如何设置电脑密码锁屏
- win10删除开机密码提示不符合密码策略要求
- 电脑w7显示不是正版（w7不是正版怎么解决）
- 万家乐z8热水器显示e7解决 怎么修复与排查方法
- 1匹空调多少瓦数（1匹空调多少瓦）
- 安卓手机连接电脑用什么软件好（关于安卓手机
- 电脑网页看视频卡是什么原因（爱拍看视频卡）
- 华帝燃气灶点火器一直响然后熄火怎么办：问题
- 电脑壁纸怎么换（关于电脑壁纸怎么换的介绍）
- 冬天空调的出风口应该朝什么方向（冬天空调风