diff --git a/src/main/scala/code/bankconnectors/KafkaHelper.scala b/src/main/scala/code/bankconnectors/KafkaHelper.scala
index 68727a910..691110920 100644
--- a/src/main/scala/code/bankconnectors/KafkaHelper.scala
+++ b/src/main/scala/code/bankconnectors/KafkaHelper.scala
@@ -13,7 +13,12 @@ import org.apache.kafka.connect.json.JsonConverter
 
 import scala.concurrent.ExecutionException
 
-object KafkaHelper extends MdcLoggable {
+object KafkaHelper extends KafkaHelper {
+
+
+}
+
+class KafkaHelper extends MdcLoggable {
 
   val requestTopic = Props.get("kafka.request_topic").openOrThrowException("no kafka.request_topic set")
   val responseTopic = Props.get("kafka.response_topic").openOrThrowException("no kafka.response_topic set")