Allow null payload for deletion feature

1 files changed, 1 insertions, 1 deletions

diff --git a/kafka/producer/base.py b/kafka/producer/base.py
index 49090bd..00e1d13 100644
--- a/kafka/producer/base.py
+++ b/kafka/producer/base.py
@@ -355,7 +355,7 @@ class Producer(object):
             raise TypeError("msg is not a list or tuple!")
 
         # Raise TypeError if any message is not encoded as bytes
-        if any(not isinstance(m, six.binary_type) for m in msg):
+        if any(m is not None and not isinstance(m, six.binary_type) for m in msg):
             raise TypeError("all produce message payloads must be type bytes")
 
         # Raise TypeError if topic is not encoded as bytes