Searched on Google with the first line of a JAVA stack trace?

We can recommend more relevant solutions and speed up debugging when you paste your entire stack trace with the exception message. Try a sample exception.

Recommended solutions based on your search

Solutions on the web

via Cask Community Issue Tracker by Alex Baranau, 2 years ago
Event queue is full of unsent messages, could not send event: KeyedMessage(logs.user-v1,cdap:services:metrics.processor,[B@e0e4d72)
via Google Groups by ron cai, 1 year ago
Event queue is full of unsent messages, could not send event: KeyedMessage(logs.user-v2,system:services:appfabric,system:services:appfabric,[B@24471929)
kafka.common.QueueFullException: Event queue is full of unsent messages, 
could not send event: 
KeyedMessage(logs.user-v2,system:services:appfabric,system:services:appfabric,[B@24471929)	at kafka.producer.Producer$$anonfun$asyncSend$1.apply(Producer.scala:113)	at kafka.producer.Producer$$anonfun$asyncSend$1.apply(Producer.scala:91)	at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)	at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:34)	at kafka.producer.Producer.asyncSend(Producer.scala:91)	at kafka.producer.Producer.send(Producer.scala:78)	at kafka.javaapi.producer.Producer.send(Producer.scala:33)	at co.cask.cdap.logging.appender.kafka.SimpleKafkaProducer.publish(SimpleKafkaProducer.java:62)	at co.cask.cdap.logging.appender.kafka.KafkaLogAppender.append(KafkaLogAppender.java:61)	at co.cask.cdap.logging.appender.LogAppender.append(LogAppender.java:27)	at ch.qos.logback.core.AppenderBase.doAppend(AppenderBase.java:85)	at ch.qos.logback.core.spi.AppenderAttachableImpl.appendLoopOnAppenders(AppenderAttachableImpl.java:48)	at ch.qos.logback.classic.Logger.appendLoopOnAppenders(Logger.java:280)	at ch.qos.logback.classic.Logger.callAppenders(Logger.java:267)	at ch.qos.logback.classic.Logger.buildLoggingEventAndAppend(Logger.java:449)	at ch.qos.logback.classic.Logger.filterAndLog_1(Logger.java:421)	at ch.qos.logback.classic.Logger.info(Logger.java:611)	at co.cask.cdap.security.authorization.AbstractAuthorizationService.shutDown(AbstractAuthorizationService.java:139)	at com.google.common.util.concurrent.AbstractScheduledService$1$3.run(AbstractScheduledService.java:219)	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)	at java.util.concurrent.FutureTask.run(FutureTask.java:266)	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)	at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)	at java.lang.Thread.run(Thread.java:745)