Kafka consumer loop should explicitly handle offset commit

[kinghuang]

The Kafka consumer loop currently depends on an auto-commit interval of 5000 ms to record the consumer offset. The run loop should perhaps switch to explicit commits after it successfully calls a service for a more accurate record of where the consumer has consumed to in its topic.