private static Properties generateDefaultKafkaProps(){
  Properties props=new Properties();
  props.put(KafkaSourceConstants.AUTO_COMMIT_ENABLED,KafkaSourceConstants.DEFAULT_AUTO_COMMIT);
  props.put(KafkaSourceConstants.CONSUMER_TIMEOUT,KafkaSourceConstants.DEFAULT_CONSUMER_TIMEOUT);
  props.put(KafkaSourceConstants.GROUP_ID,KafkaSourceConstants.DEFAULT_GROUP_ID);
  return props;
}

private static Properties generateDefaultKafkaProps ( ) { Properties props = new Properties ( ) ; props . put ( KafkaSourceConstants . AUTO_COMMIT_ENABLED , KafkaSourceConstants . DEFAULT_AUTO_COMMIT ) ; props . put ( KafkaSourceConstants . CONSUMER_TIMEOUT , KafkaSourceConstants . DEFAULT_CONSUMER_TIMEOUT ) ; props . put ( KafkaSourceConstants . GROUP_ID , KafkaSourceConstants . DEFAULT_GROUP_ID ) ; return props ; }
generate consumer properties object with some defaults
