// Path: kafka-eight-ex/src/main/java/com/ebay/pulsar/druid/firehose/kafka/support/util/PropertiesUtils.java
// public class PropertiesUtils {
// 	public static int getInt(Properties props, String key, int defaultValue){
// 		String v = props.getProperty(key);
// 		return v==null?defaultValue:Integer.parseInt(v);
// 	}
// 	public static Integer getInt(Properties props, String key){
// 		String v = props.getProperty(key);
// 		return v==null?null:Integer.parseInt(v);
// 	}
// 	public static long getLong(Properties props, String key, long defaultValue){
// 		String v = props.getProperty(key);
// 		return v==null?defaultValue:Long.parseLong(v);
// 	}
// 	public static String getString(Properties props, String key, String defaultValue){
// 		return props.getProperty(key,defaultValue);
// 	}
// 	public static String getString(Properties props, String key){
// 		return props.getProperty(key);
// 	}
// 	public static boolean getBoolean(Properties props, String key, boolean defaultValue){
// 		String v = props.getProperty(key);
// 		return v==null?defaultValue:Boolean.parseBoolean(v);
// 	}
// }


import com.ebay.pulsar.druid.firehose.kafka.support.util.PropertiesUtils;
import kafka.consumer.ConsumerConfig;
import java.util.Properties;
/*******************************************************************************
*  Copyright © 2012-2015 eBay Software Foundation
*  This program is licensed under the Apache 2.0 licenses.
*  Please see LICENSE for more information.
*******************************************************************************/
package com.ebay.pulsar.druid.firehose.kafka.support.data;




/**
 * This is the config bean for the kafka consumer.
 * 
 * Below is a configuration example.
 * 
 * 
 * @author qxing
 * 
 */
public class KafkaConsumerConfig extends ConsumerConfig{
	private int rebalanceableWaitInMs = 15000;
	private int retryTimes=3;
	private int sleepMsBetweenRetries=500;
	public KafkaConsumerConfig(Properties originalProps) {
		super(originalProps);
// Path: kafka-eight-ex/src/main/java/com/ebay/pulsar/druid/firehose/kafka/support/util/PropertiesUtils.java
// public class PropertiesUtils {
// 	public static int getInt(Properties props, String key, int defaultValue){
// 		String v = props.getProperty(key);
// 		return v==null?defaultValue:Integer.parseInt(v);
// 	}
// 	public static Integer getInt(Properties props, String key){
// 		String v = props.getProperty(key);
// 		return v==null?null:Integer.parseInt(v);
// 	}
// 	public static long getLong(Properties props, String key, long defaultValue){
// 		String v = props.getProperty(key);
// 		return v==null?defaultValue:Long.parseLong(v);
// 	}
// 	public static String getString(Properties props, String key, String defaultValue){
// 		return props.getProperty(key,defaultValue);
// 	}
// 	public static String getString(Properties props, String key){
// 		return props.getProperty(key);
// 	}
// 	public static boolean getBoolean(Properties props, String key, boolean defaultValue){
// 		String v = props.getProperty(key);
// 		return v==null?defaultValue:Boolean.parseBoolean(v);
// 	}
// }


// Path: kafka-eight-ex/src/main/java/com/ebay/pulsar/druid/firehose/kafka/support/data/KafkaConsumerConfig.java
import com.ebay.pulsar.druid.firehose.kafka.support.util.PropertiesUtils;
import kafka.consumer.ConsumerConfig;
import java.util.Properties;

/*******************************************************************************
*  Copyright © 2012-2015 eBay Software Foundation
*  This program is licensed under the Apache 2.0 licenses.
*  Please see LICENSE for more information.
*******************************************************************************/
package com.ebay.pulsar.druid.firehose.kafka.support.data;




/**
 * This is the config bean for the kafka consumer.
 * 
 * Below is a configuration example.
 * 
 * 
 * @author qxing
 * 
 */
public class KafkaConsumerConfig extends ConsumerConfig{
	private int rebalanceableWaitInMs = 15000;
	private int retryTimes=3;
	private int sleepMsBetweenRetries=500;
	public KafkaConsumerConfig(Properties originalProps) {
		super(originalProps);
		rebalanceableWaitInMs=PropertiesUtils.getInt(originalProps, "rebalance.first.wait.ms", 15000);