Python3 strings are not bytes
@@ -50,7 +50,7 @@ class LogTopicHandler(logging.Handler):
def emit(self, record):
msg = self.format(record)
- self.producer.send_async(str(msg), None)
+ self.producer.send_async(str(msg).encode('utf-8'), None)
def configure(level=logging.INFO):
""" Configure logger which dumps log on terminal
