Broker failure recovery

[ostronom]

Hi. I am getting very strange behaviour. Suppose we have one broker and we have subscribed to a topic there. We are happily consuming from this topic and then the broker goes down. After some time it is going up again and Kafka client is able to reconnect back, but it won't get any messages anymore, and there is no notification about this event that is exposed to fs2 code, so we can, for example, resubscribe to this topic, restart the consumer/stream or something like this.

I think this problem is common and someone can point me where to look for a solution (and maybe we can extend the documentation to cover this issue).