class ConsumerCommitServiceImpl implements ConsumerCommitService, BrokerTimerService {

	protected void commitOffset() {
		log.info("doSubmitOffset");
		while (isRunning) {
			doCommit();
			// 通过随机的方式来避免数据库的洪峰压力
			Util.sleep(soaConfig.getCommitSleepTime());
		}
	}

}