diff options
| -rw-r--r-- | glances/exports/glances_kafka.py | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/glances/exports/glances_kafka.py b/glances/exports/glances_kafka.py index 88d13bf0..f5a6127e 100644 --- a/glances/exports/glances_kafka.py +++ b/glances/exports/glances_kafka.py @@ -27,6 +27,7 @@ from glances.exports.glances_export import GlancesExport from kafka import KafkaProducer import json +import codecs class Export(GlancesExport): @@ -90,7 +91,8 @@ class Export(GlancesExport): # value=JSON dict try: self.client.send(self.topic, - key=name, + # Kafka key name needs to be bytes #1593 + key=name.encode('utf-8'), value=data) except Exception as e: logger.error("Cannot export {} stats to Kafka ({})".format(name, e)) |