diff --git a/tests/kafka/kafka_inter_container_messaging_test.go b/tests/kafka/kafka_inter_container_messaging_test.go
index 1a3521c..7a7a9d6 100644
--- a/tests/kafka/kafka_inter_container_messaging_test.go
+++ b/tests/kafka/kafka_inter_container_messaging_test.go
@@ -57,14 +57,14 @@
 		kk.Host(hostIP),
 		kk.Port(9092))
 
-	coreKafkaProxy, _ = kk.NewInterContainerProxy(
+	coreKafkaProxy = kk.NewInterContainerProxy(
 		kk.InterContainerHost(hostIP),
 		kk.InterContainerPort(9092),
 		kk.DefaultTopic(&kk.Topic{Name: "Core"}),
 		kk.MsgClient(kafkaClient),
 		kk.DeviceDiscoveryTopic(&kk.Topic{Name: affinityRouterTopic}))
 
-	adapterKafkaProxy, _ = kk.NewInterContainerProxy(
+	adapterKafkaProxy = kk.NewInterContainerProxy(
 		kk.InterContainerHost(hostIP),
 		kk.InterContainerPort(9092),
 		kk.DefaultTopic(&kk.Topic{Name: "Adapter"}),
@@ -515,7 +515,7 @@
 
 func TestDeviceDiscovery(t *testing.T) {
 	// Create an intercontainer proxy - similar to the Core
-	testProxy, _ := kk.NewInterContainerProxy(
+	testProxy := kk.NewInterContainerProxy(
 		kk.InterContainerHost(hostIP),
 		kk.InterContainerPort(9092),
 		kk.DefaultTopic(&kk.Topic{Name: "Test"}),