org.apache.flume.source.kafka
Class KafkaSourceConstants

java.lang.Object
  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()