Index: core/src/main/scala/kafka/producer/async/AsyncProducerStats.scala
===================================================================
--- core/src/main/scala/kafka/producer/async/AsyncProducerStats.scala	(revision 1303446)
+++ core/src/main/scala/kafka/producer/async/AsyncProducerStats.scala	(working copy)
@@ -30,6 +30,8 @@
 
   def getAsyncProducerDroppedEvents: Int = droppedEvents.get
 
+  def resetAsyncProducerDroppedEvents: Unit = droppedEvents.set(0)
+
   def recordDroppedEvents = droppedEvents.getAndAdd(1)
 
   def recordEvent = numEvents.getAndAdd(1)
Index: core/src/main/scala/kafka/producer/async/AsyncProducerStatsMBean.scala
===================================================================
--- core/src/main/scala/kafka/producer/async/AsyncProducerStatsMBean.scala	(revision 1303446)
+++ core/src/main/scala/kafka/producer/async/AsyncProducerStatsMBean.scala	(working copy)
@@ -20,6 +20,7 @@
 trait AsyncProducerStatsMBean {
   def getAsyncProducerEvents: Int
   def getAsyncProducerDroppedEvents: Int
+  def resetAsyncProducerDroppedEvents: Unit
 }
 
 trait AsyncProducerQueueSizeStatsMBean {