org.apache.flume.sink.kafka

Class KafkaSinkConstants

java.lang.Object

org.apache.flume.sink.kafka.KafkaSinkConstants

public class KafkaSinkConstants
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
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

Constructors

Constructor and Description
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()