Canary consumer stop consuming during a Kafka brokers rolling

[ppatierno]

While canary consumer is consuming messages and a Kafka brokers rolling runs, it could happen that canary stop consuming messages with a log like the following:

I1005 13:51:57.055686  159341 consumer.go:179] Consumer group cleanup
I1005 13:51:57.055752  159341 consumer.go:99] Consumer group consume starting...
I1005 13:51:57.063227  159341 consumer.go:102] Error consuming topic: dial tcp [::1]:9094: connect: connection refused

From now on the underneath Sarama consumer (group) is not consuming messages anymore.