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)

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

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 scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
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.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 co.cask.cdap.security.authorization.AbstractAuthorizationService.shutDown(AbstractAuthorizationService.java:139)
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)

Users with the same issue

You are the first who have seen this exception. Write a tip to help other users and build your expert profile.

Know the solutions? Share your knowledge to help other developers to debug faster.