At-least once semantics for Kafka to Cassndra ingest

[Himanshu Bari]

How to ensure that the Kafka to Cassandra ingestion pipeline in Apex will
guarantee exactly once processing semantics.
Eg. Message was read from Kafka but apex app died before it was written
successfully to Cassandra.