Updated dep voltha-go library fixing kafka issue
return error on failure to subscribe to a topic
Change-Id: Ie5fd16b6694c3c7a100300a27c9c47075349bed7
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