diff --git a/Gopkg.lock b/Gopkg.lock
index f6b3341..2ac97cc 100644
--- a/Gopkg.lock
+++ b/Gopkg.lock
@@ -235,7 +235,7 @@
 
 [[projects]]
   branch = "master"
-  digest = "1:eed0edabcd9e9549e804d5a7e13844f147687c9ece52c499ebdb04f99ce07f95"
+  digest = "1:204174f45bee615b32e0a79e85e9f5a9403b5e9591a04035e816385fbbbe2588"
   name = "github.com/opencord/voltha-go"
   packages = [
     "adapters",
@@ -249,7 +249,7 @@
     "rw_core/utils",
   ]
   pruneopts = "UT"
-  revision = "737b9e5045de3b00cd5da2b0c3c48be668e83b9d"
+  revision = "90cd955106f8b6924041e0e0d6ddf843a4ceaff4"
 
 [[projects]]
   branch = "master"
diff --git a/vendor/github.com/opencord/voltha-go/kafka/kafka_inter_container_library.go b/vendor/github.com/opencord/voltha-go/kafka/kafka_inter_container_library.go
index afad2ac..56b5fa1 100644
--- a/vendor/github.com/opencord/voltha-go/kafka/kafka_inter_container_library.go
+++ b/vendor/github.com/opencord/voltha-go/kafka/kafka_inter_container_library.go
@@ -327,6 +327,7 @@
 	if ch, err = kp.kafkaClient.Subscribe(&topic); err != nil {
 		//if ch, err = kp.Subscribe(topic); err != nil {
 		log.Errorw("failed-to-subscribe", log.Fields{"error": err, "topic": topic.Name})
+		return err
 	}
 
 	kp.defaultRequestHandlerInterface = handler