In Kafka there is no offset commit for a particular record. It can only commit offset per partition. We had implemented this using our own implementation.