| commit | 90cd955106f8b6924041e0e0d6ddf843a4ceaff4 | [log] [tgz] |
|---|---|---|
| author | Abhilash S.L <abhilash.laxmeshwar@radisys.com> | Thu Jul 18 17:30:29 2019 +0530 |
| committer | Abhilash Laxmeshwar <abhilash.laxmeshwar@radisys.com> | Fri Jul 19 05:48:38 2019 +0000 |
| tree | a5ba579435c7a4791516e3465eb549856f448bcb | |
| parent | 737b9e5045de3b00cd5da2b0c3c48be668e83b9d [diff] |
return error on failure to subscribe to a topic Change-Id: Iee35d7be2e796f1490cb6c27568dbfc63e46da34
diff --git a/kafka/kafka_inter_container_library.go b/kafka/kafka_inter_container_library.go index afad2ac..56b5fa1 100644 --- a/kafka/kafka_inter_container_library.go +++ b/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