From a4cdb9e6877b0f46e02a7be9c6068f090d8472ab Mon Sep 17 00:00:00 2001 From: Vrashabh Sontakke <86019029+Vrashabh-Sontakke@users.noreply.github.com> Date: Tue, 9 Apr 2024 19:28:51 +0530 Subject: [PATCH] Add error handling for SubscribeTopics function call This commit adds error handling to the main function in consumer_example.go file. Specifically, it checks for errors returned by the SubscribeTopics function call and exits the program with an error message if the subscription fails. This ensures robustness and graceful handling of errors during topic subscription. --- examples/consumer_example/consumer_example.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/examples/consumer_example/consumer_example.go b/examples/consumer_example/consumer_example.go index 60dfdfaef..b3f21f75d 100644 --- a/examples/consumer_example/consumer_example.go +++ b/examples/consumer_example/consumer_example.go @@ -70,6 +70,11 @@ func main() { err = c.SubscribeTopics(topics, nil) + if err != nil { + fmt.Fprintf(os.Stderr, "Failed to subscribe to topics: %v\n", err) + os.Exit(1) + } + run := true for run {