add pid to consumerinstanceid

fkie-cad · Oct 9, 2024 · 4661308 · 4661308
1 parent 26fab9e
commit 4661308
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/logprep/connector/confluent_kafka/input.py b/logprep/connector/confluent_kafka/input.py
@@ -29,6 +29,7 @@
 """
 # pylint: enable=line-too-long
 import logging
+import os
 from functools import cached_property, partial
 from socket import getfqdn
 from types import MappingProxyType
@@ -270,7 +271,9 @@ def _kafka_config(self) -> dict:
         }
         DEFAULTS.update({"client.id": getfqdn()})
         DEFAULTS.update(
-            {"group.instance.id": f"{getfqdn().strip('.')}-Pipeline{self.pipeline_index}"}
+            {
+                "group.instance.id": f"{getfqdn().strip('.')}-Pipeline{self.pipeline_index}-pid{os.getpid()}"
+            }
         )
         return DEFAULTS | self._config.kafka_config | injected_config