diff --git a/awslogs/core.py b/awslogs/core.py
index 748896e..2450cb9 100644
--- a/awslogs/core.py
+++ b/awslogs/core.py
@@ -203,7 +203,7 @@ def consumer():
                     if not isinstance(message, str):
                         message = json.dumps(message)
                 output.append(message.rstrip())
-                print(" ".join(output))
+                print(" ".join(output).encode("utf-8"))
 
                 try:
                     sys.stdout.flush()