diff options
Diffstat (limited to 'glances/exports/glances_kafka.py')
| -rw-r--r-- | glances/exports/glances_kafka.py | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/glances/exports/glances_kafka.py b/glances/exports/glances_kafka.py index c328d7f6..88d13bf0 100644 --- a/glances/exports/glances_kafka.py +++ b/glances/exports/glances_kafka.py @@ -42,11 +42,14 @@ class Export(GlancesExport): # Optionals configuration keys self.compression = None + self.tags = None # Load the Kafka configuration file section self.export_enable = self.load_conf('kafka', - mandatories=['host', 'port', 'topic'], - options=['compression']) + mandatories=['host', 'port', + 'topic'], + options=['compression', + 'tags']) if not self.export_enable: sys.exit(2) @@ -79,6 +82,8 @@ class Export(GlancesExport): # Create DB input data = dict(zip(columns, points)) + if self.tags is not None: + data.update(self.parse_tags(self.tags)) # Send stats to the kafka topic # key=<plugin name> |