Hello , What will happen to the in realtime in-memory consuming segment if a server is restarted? Do Pino start recreating the segment again after restart or I lose the data?

Server will restart consuming from previous checkpoint, no data loss.

I am actually thinking from the point of sudden and unexpected restarts or crashes. Not a proper restart.

Yes, still the same behavior. Kafka offsets are checkpointed with segments that are flushed. Any recovery restarts from that point.

Thanks Mayank, it is good to know that the checkpoints are saved and Pino can survive crashes.

👍