fix tests for http input and confluent kafka outptu

logprep/connector/http/input.py

@@ -439,10 +439,8 @@ def setup(self):
         """
 
         super().setup()
-        if not hasattr(self, "pipeline_index"):
-            raise FatalInputError(
-                self, "Necessary instance attribute `pipeline_index` could not be found."
-            )
+        if self.pipeline_index is None:
+            raise FatalInputError(self, "Necessary instance attribute `pipeline_index` is not set.")
         # Start HTTP Input only when in first process
         if self.pipeline_index != 1:
             return

tests/unit/connector/test_confluent_kafka_input.py

@@ -3,6 +3,7 @@
 # pylint: disable=wrong-import-position
 # pylint: disable=wrong-import-order
 # pylint: disable=attribute-defined-outside-init
+import os
 import socket
 from copy import deepcopy
 from unittest import mock
@@ -254,7 +255,7 @@ def test_default_config_is_injected(self, mock_consumer):
             "statistics.interval.ms": "30000",
             "bootstrap.servers": "testserver:9092",
             "group.id": "testgroup",
-            "group.instance.id": f"{socket.getfqdn().strip('.')}-PipelineNone",
+            "group.instance.id": f"{socket.getfqdn().strip('.')}-PipelineNone-pid{os.getpid()}",
             "logger": logger,
             "on_commit": self.object._commit_callback,
             "stats_cb": self.object._stats_callback,