Added private method _send_messages that can accept kwargs

1 files changed, 2 insertions, 0 deletions

diff --git a/kafka/producer/base.py b/kafka/producer/base.py
index 6c91364..c29491e 100644
--- a/kafka/producer/base.py
+++ b/kafka/producer/base.py
@@ -169,7 +169,9 @@ class Producer(object):
 
         All messages produced via this method will set the message 'key' to Null
         """
+        return self._send_messages(topic, partition, *msg)
 
+    def _send_messages(self, topic, partition, *msg, **kwargs):
         # Guarantee that msg is actually a list or tuple (should always be true)
         if not isinstance(msg, (list, tuple)):
             raise TypeError("msg is not a list or tuple!")