I am seeing this in error in producer after upgrading broker to 0.10.0
2016-08-19 22:18:30.598 c.y.a.t.s.o.KafkaMessageSender pool-10-thread-5
[WARN] caught exception when sending msg to kafka
kafka.common.QueueFullException: Event queue is full of unsent messages,
could not send event: KeyedMessage(targeting_stats_raw,null,null,{"event_time":
1471645110598, "source": "NRT", "entity": "SEGMENT", "entity_id":
[20590971], "colo": "GQ1", "phase": "OUTPUT", "debug_info": null,
"user_id": "7i6r0gdbjflek", "user_id_type": "BID", "count": 1})
at kafka.producer.Producer$$anonfun$asyncSend$1.apply(Producer.scala:113)
~[stormjar.jar:0.4.429]
at kafka.producer.Producer$$anonfun$asyncSend$1.apply(Producer.scala:91)
~[stormjar.jar:0.4.429]
at
scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
~[stormjar.jar:0.4.429]
at scala.collection.mutable.WrappedArray.foreach(WrappedArray.scala:34)
~[stormjar.jar:0.4.429]
at kafka.producer.Producer.asyncSend(Producer.scala:91)
~[stormjar.jar:0.4.429]
at kafka.producer.Producer.send(Producer.scala:78) ~[stormjar.jar:0.4.429]
at kafka.javaapi.producer.Producer.send(Producer.scala:33)
~[stormjar.jar:0.4.429]
at com.go.ads.targeting.stats.output.KafkaMessageSender.
write(KafkaMessageSender.java:69) [stormjar.jar:0.4.429]
which parameter i need to tune in broker config to fix this.
I use all default values in broker configs.
