From a981c8f2c8781a4f71664823e4ef7ea0b52915dc Mon Sep 17 00:00:00 2001
From: Patrick Godwin <patrick.godwin@ligo.org>
Date: Thu, 12 Jul 2018 07:45:26 -0700
Subject: [PATCH] feature_extractor.py: enforce that kafka topics are also tied
to a specific job id
---
gstlal-burst/python/fxtools/feature_extractor.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/gstlal-burst/python/fxtools/feature_extractor.py b/gstlal-burst/python/fxtools/feature_extractor.py
index a261c3fe63..fec979f207 100644
--- a/gstlal-burst/python/fxtools/feature_extractor.py
+++ b/gstlal-burst/python/fxtools/feature_extractor.py
@@ -144,7 +144,7 @@ class MultiChannelHandler(simplehandler.Handler):
elif self.save_format == 'kafka':
self.data_transfer = options.data_transfer
self.kafka_partition = options.kafka_partition
- self.kafka_topic = options.kafka_topic
+ self.kafka_topic = '_'.join([options.kafka_topic, self.job_id])
self.kafka_conf = {'bootstrap.servers': options.kafka_server}
self.producer = Producer(self.kafka_conf)
--
GitLab