diff --git a/tests/kafka/kafka_inter_container_messaging_test.go b/tests/kafka/kafka_inter_container_messaging_test.go
index 57e7ab9..de97558 100644
--- a/tests/kafka/kafka_inter_container_messaging_test.go
+++ b/tests/kafka/kafka_inter_container_messaging_test.go
@@ -524,7 +524,7 @@
 	time.Sleep(time.Millisecond * 100)
 
 	// Send the message
-	go testProxy.DeviceDiscovered("TestDeviceId", "TestDevicetype", "TestParentId")
+	go testProxy.DeviceDiscovered("TestDeviceId", "TestDevicetype", "TestParentId", "myPODName")
 
 	msg := <-waitingChannel
 	totalTime := (time.Now().UnixNano() - msg.Header.Timestamp) / int64(time.Millisecond)
@@ -536,6 +536,7 @@
 	assert.Equal(t, dd.Id, "TestDeviceId")
 	assert.Equal(t, dd.DeviceType, "TestDevicetype")
 	assert.Equal(t, dd.ParentId, "TestParentId")
+	assert.Equal(t, dd.Publisher, "myPODName")
 	log.Debugw("TotalTime", log.Fields{"time": totalTime})
 }