package com.inmobi.messaging.consumer.databus;

import com.inmobi.databus.FSCheckpointProvider;

/**
 * Configuration properties and their default values for {@link DatabusConsumer}
 */
public interface DatabusConsumerConfig {

  public static final String queueSizeConfig = "databus.consumer.buffer.size";
  public static final int DEFAULT_QUEUE_SIZE = 5000;
  
  public static final String waitTimeForFlushConfig = 
  "databus.consumer.waittime.forcollectorflush";
  public static final long DEFAULT_WAIT_TIME_FOR_FLUSH = 1000; // 1 second
  
  public static final String databusConfigFileKey = "databus.conf";
  public static final String DEFAULT_DATABUS_CONFIG_FILE = "databus.xml";

  public static final String databusClustersConfig = "databus.consumer.clusters";
  
  public static final String databusChkProviderConfig = 
      "databus.consumer.chkpoint.provider.classname";
  public static final String DEFAULT_CHK_PROVIDER = FSCheckpointProvider.class
  .getName();

  public static final String checkpointDirConfig = 
  "databus.consumer.checkpoint.dir";
  public static final String DEFAULT_CHECKPOINT_DIR = ".";
  
  public static final String databusConsumerPrincipal = 
      "databus.consumer.principal.name";
  public static final String databusConsumerKeytab = 
      "databus.consumer.keytab.path";
  
}

package com.inmobi.messaging.consumer.databus;

import com.inmobi.databus.FSCheckpointProvider;

/**
 * Configuration properties and their default values for {@link DatabusConsumer}
 */
public interface DatabusConsumerConfig {

  public static final String queueSizeConfig = "databus.consumer.buffer.size";
  public static final int DEFAULT_QUEUE_SIZE = 5000;
  
  public static final String waitTimeForFlushConfig = 
  "databus.consumer.waittime.forcollectorflush";
  public static final long DEFAULT_WAIT_TIME_FOR_FLUSH = 1000; // 1 second
  
  public static final String databusConfigFileKey = "databus.conf";
  public static final String DEFAULT_DATABUS_CONFIG_FILE = "databus.xml";

  public static final String databusClustersConfig = "databus.consumer.clusters";
  
  public static final String databusChkProviderConfig = 
      "databus.consumer.chkpoint.provider.classname";
  public static final String DEFAULT_CHK_PROVIDER = FSCheckpointProvider.class
  .getName();

  public static final String checkpointDirConfig = 
  "databus.consumer.checkpoint.dir";
  public static final String DEFAULT_CHECKPOINT_DIR = ".";
  
}

--- 
+++ 
@@ -28,4 +28,9 @@
   "databus.consumer.checkpoint.dir";
   public static final String DEFAULT_CHECKPOINT_DIR = ".";
   
+  public static final String databusConsumerPrincipal = 
+      "databus.consumer.principal.name";
+  public static final String databusConsumerKeytab = 
+      "databus.consumer.keytab.path";
+  
 }
Fix typo in Config name
