diff --git a/gstlal-burst/python/fxtools/feature_extractor.py b/gstlal-burst/python/fxtools/feature_extractor.py
index a261c3fe639e94750d1ed06c6cb916fd4e3e573e..fec979f207c97487bc0016175ce1696b6b9bcab2 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)