From 62dbeb369efe8bb6c09b719835463ba71d2cec09 Mon Sep 17 00:00:00 2001
From: nicolargo <nicolashennion@gmail.com>
Date: Thu, 27 Feb 2020 15:28:28 +0100
Subject: Kafka key name needs to be bytes #1593

---
 glances/exports/glances_kafka.py | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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))
-- 
cgit v1.2.3