add missing thing from the rebase

Author: EXBreder

osprey_worker/src/osprey/worker/sinks/input_stream_chooser.py

@@ -99,10 +99,14 @@ def get_rules_sink_input_stream(
     elif input_stream_source == InputStreamSource.KAFKA:
         config = CONFIG.instance()
         client_id = config.get_str('OSPREY_KAFKA_INPUT_STREAM_CLIENT_ID', 'localhost')
+        client_id_suffix = config.get_optional_str('OSPREY_KAFKA_INPUT_STREAM_CLIENT_ID_SUFFIX')
         input_topic: str = config.get_str('OSPREY_KAFKA_INPUT_STREAM_TOPIC', 'osprey.actions_input')
         input_bootstrap_servers: list[str] = config.get_str_list('OSPREY_KAFKA_BOOTSTRAP_SERVERS', ['localhost'])
         group_id = config.get_optional_str('OSPREY_KAFKA_GROUP_ID')
 
+        if client_id_suffix:
+            client_id = f'{client_id}-{client_id_suffix}'
+
         consumer: PatchedKafkaConsumer = PatchedKafkaConsumer(
             input_topic,
             bootstrap_servers=input_bootstrap_servers,