From 8b74a05d8b547367b45812301bd05d8aa41df97e Mon Sep 17 00:00:00 2001
From: Patrick Godwin <patrick.godwin@ligo.org>
Date: Wed, 8 May 2019 06:50:45 -0700
Subject: [PATCH] gstlal_feature_hdf5_sink: generate kafka group name from tag
+ process name
---
gstlal-burst/bin/gstlal_feature_hdf5_sink | 7 +++++--
1 file changed, 5 insertions(+), 2 deletions(-)
diff --git a/gstlal-burst/bin/gstlal_feature_hdf5_sink b/gstlal-burst/bin/gstlal_feature_hdf5_sink
index a26802e62a..d5922d82a1 100755
--- a/gstlal-burst/bin/gstlal_feature_hdf5_sink
+++ b/gstlal-burst/bin/gstlal_feature_hdf5_sink
@@ -91,6 +91,7 @@ class HDF5StreamSink(object):
"""
def __init__(self, logger, options):
logger.info('setting up hdf5 stream sink...')
+ self.tag = options.tag
### initialize timing options
self.request_timeout = options.request_timeout
@@ -98,8 +99,10 @@ class HDF5StreamSink(object):
self.is_running = False
### kafka settings
- self.kafka_settings = {'bootstrap.servers': options.kafka_server,
- 'group.id': 'group_1'}
+ self.kafka_settings = {
+ 'bootstrap.servers': options.kafka_server,
+ 'group.id': 'hdf5_sink_{}'.format(self.tag)
+ }
### initialize consumers
self.consumer = Consumer(self.kafka_settings)
--
GitLab