Exactly-Once semantics for Kafka Ingestion

Working on achieving exactly-once semantics for the Kafka ingestion, will involve discarding the insertion of already-present records based on the stored offset. This will involve allowing the records only if the

(stored offset) < (offset present in the record)

This will also help in the consistency of the query results.