diff --git a/nsqd/nsqd.go b/nsqd/nsqd.go index 70dbd76ca..569b1a91d 100644 --- a/nsqd/nsqd.go +++ b/nsqd/nsqd.go @@ -444,7 +444,10 @@ func (n *NSQD) GetTopic(topicName string) *Topic { // this makes sure that any message received is buffered to the right channels lookupdHTTPAddrs := n.lookupdHTTPAddrs() if len(lookupdHTTPAddrs) > 0 { - channelNames, _ := n.ci.GetLookupdTopicChannels(t.name, lookupdHTTPAddrs) + channelNames, err := n.ci.GetLookupdTopicChannels(t.name, lookupdHTTPAddrs) + if err != nil { + n.logf("ERROR: failed to get channels for pre-creation for topic %s - %s", t.name, err) + } for _, channelName := range channelNames { if strings.HasSuffix(channelName, "#ephemeral") { // we don't want to pre-create ephemeral channels