949596979899100101102103104
}else { LOG.info("Don't reset meta offset "); } consumer.start(); consumers.put(key, consumer); LOG.info("Successfully create " + key + " consumer");