public static void main(String[] args) throws ParseException {
		Map<String, String> argMap = parseCmdOptions(args);
		if (argMap == null || argMap.isEmpty())
			return;
		/*
		 * String zooKeeper = "14.63.199.135"; String groupId =
		 * "kafka2esLocal2"; String topic = "yoodoc1";
		 */
		String zooKeeper = argMap.get(OPTION_ZOOKEEPER);
		String groupId = argMap.get(OPTION_GROUP);
		String topic = argMap.get(OPTION_TOPIC);
		String fetchSize = argMap.get(OPTION_TOPIC);

		Kafka2EsMultiConsumer worker = new Kafka2EsMultiConsumer(zooKeeper,
				groupId, topic);
		int numOfthreads = 1;

		worker.run(numOfthreads);
		try {
			Thread.sleep(1000000);
		} catch (InterruptedException ie) {
			ie.printStackTrace();
		}
		worker.shutdown();
	}