nicolargo/glances
1
1
Fork 0
mirror of https://github.com/nicolargo/glances.git synced 2024-11-28 05:42:57 +03:00
Code Issues Projects Releases Wiki Activity

Kafka key name needs to be bytes #1593

Browse Source
This commit is contained in:
nicolargo 2020-02-27 15:28:28 +01:00
parent f6533272a5
commit 62dbeb369e
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
glances/exports/glances_kafka.py
View File

@ -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))