diff --git a/main_test.go b/main_test.go
index 84e2981..13f760c 100644
--- a/main_test.go
+++ b/main_test.go
@@ -156,7 +156,7 @@
 
 	ad := newMockAdapter()
 
-	kip, _ := kafka.NewInterContainerProxy(
+	kip := kafka.NewInterContainerProxy(
 		kafka.InterContainerHost(ad.config.KafkaAdapterHost),
 		kafka.InterContainerPort(ad.config.KafkaAdapterPort),
 		kafka.MsgClient(&mockKafkaClient{}),
@@ -228,3 +228,7 @@
 func (kc *mockKafkaClient) EnableHealthinessChannel(enable bool) chan bool {
 	return nil
 }
+
+func (kc *mockKafkaClient) SubscribeForMetadata(func(fromTopic string, timestamp int64)) {
+	return
+}