diff options
Diffstat (limited to 'glances/exports/glances_kafka.py')
| -rw-r--r-- | glances/exports/glances_kafka.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/glances/exports/glances_kafka.py b/glances/exports/glances_kafka.py index 275b9595..ccb51b43 100644 --- a/glances/exports/glances_kafka.py +++ b/glances/exports/glances_kafka.py @@ -13,9 +13,9 @@ import sys from glances.logger import logger from glances.exports.glances_export import GlancesExport +from glances.globals import json_dumps from kafka import KafkaProducer -import json class Export(GlancesExport): @@ -54,7 +54,7 @@ class Export(GlancesExport): try: s = KafkaProducer( bootstrap_servers=server_uri, - value_serializer=lambda v: json.dumps(v).encode('utf-8'), + value_serializer=lambda v: json_dumps(v).encode('utf-8'), compression_type=self.compression, ) except Exception as e: |