KafkaIO reading from latest offset when pipeline fails on FlinkRunner

[Sushil Ks]

Hi,
         I am running a fixed window with GroupByKey on FlinkRunner and
have noticed that any exception and restart before the GroupByKey operation
the Kafka consumer is replaying the data from the particular offset,
however, post that any exception occurs and the pipeline restart the Kafka
is consuming from the latest offset. Is this expected?

Regards,
Sushil Ks