diff options
Diffstat (limited to 'kafka')
| -rw-r--r-- | kafka/producer.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/kafka/producer.py b/kafka/producer.py index fb83da6..687bb2d 100644 --- a/kafka/producer.py +++ b/kafka/producer.py @@ -180,7 +180,7 @@ class Producer(object): # Raise TypeError if any message is not encoded as bytes if any(not isinstance(m, six.binary_type) for m in msg): - raise TypeError("all produce message payloads must be type str") + raise TypeError("all produce message payloads must be type bytes") if self.async: for m in msg: |