Loading...

Type: Bug
Resolution: Done
Priority: Medium
Fix Version/s: Casablanca Release
Affects Version/s: Amsterdam Release
Labels:
- Integration
Environment:

Integration Lab, Wind River Environment

Epic Link:
Message Router (MR)
Sprint:
DMAAP 05 10/02-10/13

14:17:28.632 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: SDC-DISTR-NOTIF-TOPIC-AUTO

14:17:28.784 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: SDC-DISTR-NOTIF-TOPIC-AUTO

14:17:28.936 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: SDC-DISTR-NOTIF-TOPIC-AUTO

14:17:29.088 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: SDC-DISTR-NOTIF-TOPIC-AUTO

14:17:29.240 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: SDC-DISTR-NOTIF-TOPIC-AUTO

14:17:29.392 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: SDC-DISTR-NOTIF-TOPIC-AUTO

14:17:29.543 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to send requests for topics SDC-DISTR-NOTIF-TOPIC-AUTO with correlation ids in [856,867]

14:17:29.543 [qtp379110473-612] ERROR com.att.nsa.cambria.backends.kafka.KafkaPublisher - Failed to send message(s) to topic [SDC-DISTR-NOTIF-TOPIC-AUTO].

kafka.common.FailedToSendMessageException: Failed to send messages after 5 tries.

at kafka.producer.async.DefaultEventHandler.handle(DefaultEventHandler.scala:90)

at kafka.producer.Producer.send(Producer.scala:77)

at kafka.javaapi.producer.Producer.send(Producer.scala:42)

at com.att.nsa.cambria.backends.kafka.KafkaPublisher.sendBatchMessage(KafkaPublisher.java:118)

at com.att.nsa.cambria.service.impl.EventsServiceImpl.pushEvents(EventsServiceImpl.java:471)

at com.att.nsa.cambria.service.impl.EventsServiceImpl.pushEvents(EventsServiceImpl.java:408)

at com.att.nsa.dmaap.service.EventsRestService.pushEvents(EventsRestService.java:202)

at sun.reflect.GeneratedMethodAccessor83.invoke(Unknown Source)

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

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

at org.apache.cxf.service.invoker.AbstractInvoker.performInvocation(AbstractInvoker.java:181)

at org.apache.cxf.service.invoker.AbstractInvoker.invoke(AbstractInvoker.java:97)

at org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:200)

at org.apache.cxf.jaxrs.JAXRSInvoker.invoke(JAXRSInvoker.java:99)

at org.apache.cxf.interceptor.ServiceInvokerInterceptor$1.run(ServiceInvokerInterceptor.java:59)

at org.apache.cxf.interceptor.ServiceInvokerInterceptor.handleMessage(ServiceInvokerInterceptor.java:96)

at org.apache.cxf.phase.PhaseInterceptorChain.doIntercept(PhaseInterceptorChain.java:307)

at org.apache.cxf.transport.ChainInitiationObserver.onMessage(ChainInitiationObserver.java:121)

at org.apache.camel.component.cxf.cxfbean.CxfBeanDestination.process(CxfBeanDestination.java:83)

at org.apache.camel.impl.ProcessorEndpoint.onExchange(ProcessorEndpoint.java:103)

at org.apache.camel.impl.ProcessorEndpoint$1.process(ProcessorEndpoint.java:71)

at org.apache.camel.util.AsyncProcessorConverterHelper$ProcessorToAsyncProcessorBridge.process(AsyncProcessorConverterHelper.java:61)

at org.apache.camel.processor.SendProcessor.process(SendProcessor.java:129)

at org.apache.camel.management.InstrumentationProcessor.process(InstrumentationProcessor.java:77)

at org.apache.camel.processor.RedeliveryErrorHandler.process(RedeliveryErrorHandler.java:448)

at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)

at org.apache.camel.processor.Pipeline.process(Pipeline.java:118)

at org.apache.camel.processor.Pipeline.process(Pipeline.java:80)

at org.apache.camel.processor.CamelInternalProcessor.process(CamelInternalProcessor.java:190)

at org.apache.camel.util.AsyncProcessorHelper.process(AsyncProcessorHelper.java:109)

at org.apache.camel.processor.DelegateAsyncProcessor.process(DelegateAsyncProcessor.java:87)

at org.apache.camel.component.http.CamelServlet.service(CamelServlet.java:144)

at ajsc.servlet.AjscCamelServlet.service(AjscCamelServlet.java:66)

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

at org.eclipse.jetty.servlet.ServletHolder.handle(ServletHolder.java:808)

at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1669)

at ajsc.filter.PassthruFilter.doFilter(PassthruFilter.java:26)

at org.springframework.web.filter.DelegatingFilterProxy.invokeDelegate(DelegatingFilterProxy.java:343)

at org.springframework.web.filter.DelegatingFilterProxy.doFilter(DelegatingFilterProxy.java:260)

at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1652)

at com.att.ajsc.csi.writeablerequestfilter.WriteableRequestFilter.doFilter(WriteableRequestFilter.java:41)

at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1652)

at com.att.nsa.dmaap.util.DMaaPAuthFilter.doFilter(DMaaPAuthFilter.java:108)

at org.eclipse.jetty.servlet.ServletHandler$CachedChain.doFilter(ServletHandler.java:1652)

at org.eclipse.jetty.servlet.ServletHandler.doHandle(ServletHandler.java:585)

at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:143)

at org.eclipse.jetty.security.SecurityHandler.handle(SecurityHandler.java:577)

at org.eclipse.jetty.server.session.SessionHandler.doHandle(SessionHandler.java:223)

at org.eclipse.jetty.server.handler.ContextHandler.doHandle(ContextHandler.java:1127)

at org.eclipse.jetty.servlet.ServletHandler.doScope(ServletHandler.java:515)

at org.eclipse.jetty.server.session.SessionHandler.doScope(SessionHandler.java:185)

at org.eclipse.jetty.server.handler.ContextHandler.doScope(ContextHandler.java:1061)

at org.eclipse.jetty.server.handler.ScopedHandler.handle(ScopedHandler.java:141)

at org.eclipse.jetty.server.handler.ContextHandlerCollection.handle(ContextHandlerCollection.java:215)

at org.eclipse.jetty.server.handler.HandlerWrapper.handle(HandlerWrapper.java:97)

at org.eclipse.jetty.server.Server.handle(Server.java:497)

at org.eclipse.jetty.server.HttpChannel.handle(HttpChannel.java:310)

at org.eclipse.jetty.server.HttpConnection.onFillable(HttpConnection.java:257)

at org.eclipse.jetty.io.AbstractConnection$2.run(AbstractConnection.java:540)

at org.eclipse.jetty.util.thread.QueuedThreadPool.runJob(QueuedThreadPool.java:635)

at org.eclipse.jetty.util.thread.QueuedThreadPool$3.run(QueuedThreadPool.java:555)

at java.lang.Thread.run(Thread.java:745)

14:17:46.508 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: msgrtr.apinode.metrics.dmaap

14:17:46.660 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: msgrtr.apinode.metrics.dmaap

14:17:46.812 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: msgrtr.apinode.metrics.dmaap

14:17:46.964 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: msgrtr.apinode.metrics.dmaap

14:17:47.115 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: msgrtr.apinode.metrics.dmaap

14:17:47.267 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to collate messages by topic, partition due to: Failed to fetch topic metadata for topic: msgrtr.apinode.metrics.dmaap

14:17:47.418 [qtp379110473-612] ERROR kafka.producer.async.DefaultEventHandler - Failed to send requests for topics msgrtr.apinode.metrics.dmaap with correlation ids in [868,879]

14:17:47.419 [qtp379110473-612] ERROR com.att.nsa.cambria.backends.kafka.KafkaPublisher - Failed to send message(s) to topic [msgrtr.apinode.metrics.dmaap].