diff --git a/examples/consumer_example/consumer_example.go b/examples/consumer_example/consumer_example.go index 60dfdfaef..1f1a7262d 100644 --- a/examples/consumer_example/consumer_example.go +++ b/examples/consumer_example/consumer_example.go @@ -69,6 +69,10 @@ func main() { fmt.Printf("Created Consumer %v\n", c) 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