org.apache.flume.sink.kafka
Class KafkaSinkConstants

java.lang.Object
  org.apache.flume.sink.kafka.KafkaSinkConstants

public class KafkaSinkConstants
extends Object

Field Summary

static String	BATCH_SIZE
static String	BROKER_LIST_FLUME_KEY
static String	BROKER_LIST_KEY
static int	DEFAULT_BATCH_SIZE
static String	DEFAULT_KEY_SERIALIZER
static String	DEFAULT_MESSAGE_SERIALIZER
static String	DEFAULT_REQUIRED_ACKS
static String	DEFAULT_TOPIC
static String	KEY_SERIALIZER_KEY
static String	MESSAGE_SERIALIZER_KEY
static String	PROPERTY_PREFIX
static String	REQUIRED_ACKS_FLUME_KEY
static String	REQUIRED_ACKS_KEY
static String	TOPIC

Constructor Summary

KafkaSinkConstants()

Method Summary

Methods inherited from class java.lang.Object

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

Field Detail

PROPERTY_PREFIX

public static final String PROPERTY_PREFIX

See Also:

Constant Field Values

TOPIC

public static final String TOPIC

See Also:

Constant Field Values

BATCH_SIZE

public static final String BATCH_SIZE

See Also:

Constant Field Values

MESSAGE_SERIALIZER_KEY

public static final String MESSAGE_SERIALIZER_KEY

See Also:

Constant Field Values

KEY_SERIALIZER_KEY

public static final String KEY_SERIALIZER_KEY

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

REQUIRED_ACKS_FLUME_KEY

public static final String REQUIRED_ACKS_FLUME_KEY

See Also:

Constant Field Values

DEFAULT_BATCH_SIZE

public static final int DEFAULT_BATCH_SIZE

See Also:

Constant Field Values

DEFAULT_TOPIC

public static final String DEFAULT_TOPIC

See Also:

Constant Field Values

DEFAULT_MESSAGE_SERIALIZER

public static final String DEFAULT_MESSAGE_SERIALIZER

See Also:

Constant Field Values

DEFAULT_KEY_SERIALIZER

public static final String DEFAULT_KEY_SERIALIZER

See Also:

Constant Field Values

DEFAULT_REQUIRED_ACKS

public static final String DEFAULT_REQUIRED_ACKS

See Also:

Constant Field Values

Constructor Detail

KafkaSinkConstants

public KafkaSinkConstants()