By default, sarama outputs error messages to stdout

[sbowman]

Some of the functionality in sarama-cluster relies on sarama passing error messages to the PartitionConsumer.Errors() channel. However, by default sarama will simply write errors from Kafka to the logger (stdout).

To support sarama-cluster, you need to configure the sarama.Client with Consumer.Return.Errors:

config := sarama.NewConfig()
config.Consumer.Return.Errors = true
client, err := sarama.NewClient(servers, config)

//...

consumer, err := cluster.NewConsumerFromClient(client, zookeepers, group, topic, clusterConfig)

It's only blind luck that I stumbled across this. This seems like a pretty big deal, but it's just briefly mentioned in one or two places in the sarama docs. See the description under https://godoc.org/github.com/Shopify/sarama#PartitionConsumer and the comments in https://godoc.org/github.com/Shopify/sarama#Config, under "Consumer".

[dim]

Fixed in dae70a7