Index: core/src/main/scala/kafka/producer/async/ProducerSendThread.scala
===================================================================
--- core/src/main/scala/kafka/producer/async/ProducerSendThread.scala	(revision 1397281)
+++ core/src/main/scala/kafka/producer/async/ProducerSendThread.scala	(working copy)
@@ -93,6 +93,8 @@
           events = new ListBuffer[ProducerData[K,V]]
         }
     }
+    // send the last batch of events
+    tryToHandle(events)
     if(queue.size > 0)
       throw new IllegalQueueStateException("Invalid queue state! After queue shutdown, %d remaining items in the queue"
         .format(queue.size))