org.apache.flume.source.kafka
Class KafkaSourceConstants

java.lang.Object
  extended by org.apache.flume.source.kafka.KafkaSourceConstants

public class KafkaSourceConstants
extends Object


Field Summary
static String AUTO_COMMIT_ENABLED
           
static String BATCH_DURATION_MS
           
static String BATCH_SIZE
           
static String CONSUMER_TIMEOUT
           
static String DEFAULT_AUTO_COMMIT
           
static int DEFAULT_BATCH_DURATION
           
static int DEFAULT_BATCH_SIZE
           
static String DEFAULT_CONSUMER_TIMEOUT
           
static String DEFAULT_GROUP_ID
           
static String GROUP_ID
           
static String GROUP_ID_FLUME
           
static String KEY
           
static String PROPERTY_PREFIX
           
static String TIMESTAMP
           
static String TOPIC
           
static String ZOOKEEPER_CONNECT
           
static String ZOOKEEPER_CONNECT_FLUME
           
 
Constructor Summary
KafkaSourceConstants()
           
 
Method Summary
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

TOPIC

public static final String TOPIC
See Also:
Constant Field Values

KEY

public static final String KEY
See Also:
Constant Field Values

TIMESTAMP

public static final String TIMESTAMP
See Also:
Constant Field Values

BATCH_SIZE

public static final String BATCH_SIZE
See Also:
Constant Field Values

BATCH_DURATION_MS

public static final String BATCH_DURATION_MS
See Also:
Constant Field Values

CONSUMER_TIMEOUT

public static final String CONSUMER_TIMEOUT
See Also:
Constant Field Values

AUTO_COMMIT_ENABLED

public static final String AUTO_COMMIT_ENABLED
See Also:
Constant Field Values

ZOOKEEPER_CONNECT

public static final String ZOOKEEPER_CONNECT
See Also:
Constant Field Values

ZOOKEEPER_CONNECT_FLUME

public static final String ZOOKEEPER_CONNECT_FLUME
See Also:
Constant Field Values

GROUP_ID

public static final String GROUP_ID
See Also:
Constant Field Values

GROUP_ID_FLUME

public static final String GROUP_ID_FLUME
See Also:
Constant Field Values

PROPERTY_PREFIX

public static final String PROPERTY_PREFIX
See Also:
Constant Field Values

DEFAULT_BATCH_SIZE

public static final int DEFAULT_BATCH_SIZE
See Also:
Constant Field Values

DEFAULT_BATCH_DURATION

public static final int DEFAULT_BATCH_DURATION
See Also:
Constant Field Values

DEFAULT_CONSUMER_TIMEOUT

public static final String DEFAULT_CONSUMER_TIMEOUT
See Also:
Constant Field Values

DEFAULT_AUTO_COMMIT

public static final String DEFAULT_AUTO_COMMIT
See Also:
Constant Field Values

DEFAULT_GROUP_ID

public static final String DEFAULT_GROUP_ID
See Also:
Constant Field Values
Constructor Detail

KafkaSourceConstants

public KafkaSourceConstants()


Copyright © 2009-2015 Apache Software Foundation. All Rights Reserved.