diff options
| -rw-r--r-- | kafka/producer/base.py | 2 |
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!") |