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)

There are no available Samebug tips for this exception. Do you have an idea how to solve this issue? A short tip would help users who saw this issue last week.

  • 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)[org.apache.kafka.kafka_2.10-0.8.2.2.jar:na] at kafka.producer.Producer$$anonfun$asyncSend$1.apply(Producer.scala:91)[org.apache.kafka.kafka_2.10-0.8.2.2.jar:na] at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)[org.scala-lang.scala-library-2.10.4.jar:na] at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:34)[org.scala-lang.scala-library-2.10.4.jar:na] at kafka.producer.Producer.asyncSend(Producer.scala:91)[org.apache.kafka.kafka_2.10-0.8.2.2.jar:na] at kafka.producer.Producer.send(Producer.scala:78)[org.apache.kafka.kafka_2.10-0.8.2.2.jar:na] at kafka.javaapi.producer.Producer.send(Producer.scala:33)[org.apache.kafka.kafka_2.10-0.8.2.2.jar:na] at co.cask.cdap.logging.appender.kafka.SimpleKafkaProducer.publish(SimpleKafkaProducer.java:62)[co.cask.cdap.cdap-watchdog-3.5.0.jar:na] at co.cask.cdap.logging.appender.kafka.KafkaLogAppender.append(KafkaLogAppender.java:61)[co.cask.cdap.cdap-watchdog-3.5.0.jar:na] at co.cask.cdap.logging.appender.LogAppender.append(LogAppender.java:27)[co.cask.cdap.cdap-watchdog-3.5.0.jar:na] at ch.qos.logback.core.AppenderBase.doAppend(AppenderBase.java:85)[ch.qos.logback.logback-core-1.0.9.jar:na] at ch.qos.logback.core.spi.AppenderAttachableImpl.appendLoopOnAppenders(AppenderAttachableImpl.java:48)[ch.qos.logback.logback-core-1.0.9.jar:na] at ch.qos.logback.classic.Logger.appendLoopOnAppenders(Logger.java:280)[ch.qos.logback.logback-classic-1.0.9.jar:na] at ch.qos.logback.classic.Logger.callAppenders(Logger.java:267)[ch.qos.logback.logback-classic-1.0.9.jar:na] at ch.qos.logback.classic.Logger.buildLoggingEventAndAppend(Logger.java:449)[ch.qos.logback.logback-classic-1.0.9.jar:na] at ch.qos.logback.classic.Logger.filterAndLog_1(Logger.java:421)[ch.qos.logback.logback-classic-1.0.9.jar:na] at ch.qos.logback.classic.Logger.info(Logger.java:611)[ch.qos.logback.logback-classic-1.0.9.jar:na] at co.cask.cdap.security.authorization.AbstractAuthorizationService.shutDown(AbstractAuthorizationService.java:139)[co.cask.cdap.cdap-security-3.5.0.jar:na] at com.google.common.util.concurrent.AbstractScheduledService$1$3.run(AbstractScheduledService.java:219)[com.google.guava.guava-13.0.1.jar:na] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)[na:1.8.0_60] at java.util.concurrent.FutureTask.run(FutureTask.java:266)[na:1.8.0_60] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)[na:1.8.0_60] at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)[na:1.8.0_60] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)[na:1.8.0_60] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)[na:1.8.0_60] at java.lang.Thread.run(Thread.java:745)[na:1.8.0_60]
No Bugmate found.