Refer to IBM/sarama#272 and monitor the cases in which this bug occurs, evaluation a possible workaround.
A possible workaround, or at least safe error detection, would be to retry and if not possible fail and manage the fails, when the following error occurs: LeaderNotAvailable (https://cwiki.apache.org/confluence/display/KAFKA/A+Guide+To+The+Kafka+Protocol), because that is the cause.
Of course, we first need to enable execution log collection: #43