To reproduce: * create a stream * publish messages to the stream * start a consumer with offset = next, it should not receive any messages * kill the connection of the consumer * the consumer will start consuming at offset 0, whereas it should start at next