Add ResetKafkaConsumerOffset function.