Event Driven Architecture, Exactly One Delivery, Kafka, Message Broker, Software Development.
current states. To solve the first problem, a checkpoint mechanism is usually used. Take snapshots of the states and record offsets at regular time intervals or for each batch of messages handled. When a problem occurs, just restore the last snapshot and replay the last offset to the latest data.