org.apache.flume.channel.kafka
Class KafkaChannelConfiguration

java.lang.Object
  org.apache.flume.channel.kafka.KafkaChannelConfiguration

public class KafkaChannelConfiguration
extends Object

Field Summary

static String	AUTO_COMMIT_ENABLED
static String	BROKER_LIST_FLUME_KEY
static String	BROKER_LIST_KEY
static String	CONSUMER_TIMEOUT
static String	DEFAULT_GROUP_ID
static boolean	DEFAULT_PARSE_AS_FLUME_EVENT
static boolean	DEFAULT_READ_SMALLEST_OFFSET
static String	DEFAULT_TIMEOUT
static String	DEFAULT_TOPIC
static String	GROUP_ID
static String	GROUP_ID_FLUME
static String	KAFKA_PREFIX
static String	PARSE_AS_FLUME_EVENT
static String	READ_SMALLEST_OFFSET
static String	REQUIRED_ACKS_KEY
static String	TIMEOUT
static String	TOPIC
static String	ZOOKEEPER_CONNECT
static String	ZOOKEEPER_CONNECT_FLUME_KEY

Constructor Summary

KafkaChannelConfiguration()

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

KAFKA_PREFIX

public static final String KAFKA_PREFIX

See Also:

Constant Field Values

BROKER_LIST_KEY

public static final String BROKER_LIST_KEY

See Also:

Constant Field Values

REQUIRED_ACKS_KEY

public static final String REQUIRED_ACKS_KEY

See Also:

Constant Field Values

BROKER_LIST_FLUME_KEY

public static final String BROKER_LIST_FLUME_KEY

See Also:

Constant Field Values

TOPIC

public static final String TOPIC

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

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_KEY

public static final String ZOOKEEPER_CONNECT_FLUME_KEY

See Also:

Constant Field Values

DEFAULT_GROUP_ID

public static final String DEFAULT_GROUP_ID

See Also:

Constant Field Values

DEFAULT_TOPIC

public static final String DEFAULT_TOPIC

See Also:

Constant Field Values

TIMEOUT

public static final String TIMEOUT

See Also:

Constant Field Values

DEFAULT_TIMEOUT

public static final String DEFAULT_TIMEOUT

See Also:

Constant Field Values

CONSUMER_TIMEOUT

public static final String CONSUMER_TIMEOUT

See Also:

Constant Field Values

PARSE_AS_FLUME_EVENT

public static final String PARSE_AS_FLUME_EVENT

See Also:

Constant Field Values

DEFAULT_PARSE_AS_FLUME_EVENT

public static final boolean DEFAULT_PARSE_AS_FLUME_EVENT

See Also:

Constant Field Values

READ_SMALLEST_OFFSET

public static final String READ_SMALLEST_OFFSET

See Also:

Constant Field Values

DEFAULT_READ_SMALLEST_OFFSET

public static final boolean DEFAULT_READ_SMALLEST_OFFSET

See Also:

Constant Field Values

Constructor Detail

KafkaChannelConfiguration

public KafkaChannelConfiguration()