Hi All I'm looking into the case of Kafka broker failures with regard to offset management and state checkpointing. As far as I understood the offsets and state checkpoints are stored in separate Kafka topics and happen at the same time. Therefore if a samza job fails it will restore the state from the corresponding Kafka topics. Now what happens if for example the offset topic is available, but the data of the checkpoint topic is lost due to Kafka broker failures? I'm guessing Kafka restores the offset and continues as if there was never any state stored. Is this correct?
Best Nicolas
