diff --git a/kombu/utils/encoding.py b/kombu/utils/encoding.py index 93788bde..551cf5f3 100644 --- a/kombu/utils/encoding.py +++ b/kombu/utils/encoding.py @@ -53,7 +53,7 @@ if PY3: # pragma: no cover def bytes_to_str(s): """Convert bytes to str.""" if isinstance(s, bytes): - return s.decode() + return s.decode(errors='replace') return s def from_utf8(s, *args, **kwargs):