Added private method _send_messages that can accept kwargs

quard8 · Nov 26, 2014 · 7041a27 · 7041a27
1 parent 8138987
commit 7041a27
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/kafka/producer/base.py b/kafka/producer/base.py
@@ -169,7 +169,9 @@ def send_messages(self, topic, partition, *msg):
 
         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!")