| commit | eb5059f4e1fa7952e4a60e56dc1e99a046ffa293 | [log] [tgz] |
|---|---|---|
| author | Matt Jeanneret <mj3580@att.com> | Fri Jul 19 06:11:00 2019 -0400 |
| committer | Matt Jeanneret <mj3580@att.com> | Fri Jul 19 06:11:00 2019 -0400 |
| tree | 84d2829af793c8104e4ab5b93a9d9edc4590f3f0 | |
| parent | 0c9ae28f556ea5f3950355fb5f147a4eeecd1900 [diff] [blame] |
Updated dep voltha-go library fixing kafka issue return error on failure to subscribe to a topic Change-Id: Ie5fd16b6694c3c7a100300a27c9c47075349bed7
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