Package org.wso2.carbon.inbound.endpoint.protocol.kafka

Class KAFKAConstants

java.lang.Object

org.wso2.carbon.inbound.endpoint.protocol.kafka.KAFKAConstants

public class KAFKAConstants
extends Object

The constant parameters for kafka protocol

Field Summary

Fields

Modifier and Type	Field	Description
static final int	BUFFER_SIZE
static final String	CONSUMER_TIMEOUT
static final String	CONSUMER_TYPE
static final String	CONTENT_TYPE
static final String	FILTER_FROM_WHITE_LIST
static final String	GROUP_ID
static final String	SIMPLE_BROKERS
static final String	SIMPLE_MAX_MSG_TO_READ
static final String	SIMPLE_PARTITION
static final String	SIMPLE_PORT
static final String	SIMPLE_TOPIC
static final int	SO_TIMEOUT
static final String	THREAD_COUNT
static final String	TOPIC_FILTER
static final String	TOPICS
static final String	ZOOKEEPER_COMMIT_INTERVAL_MS
static final String	ZOOKEEPER_CONNECT
static final String	ZOOKEEPER_SESSION_TIMEOUT_MS
static final String	ZOOKEEPER_SYNC_TIME_MS

Constructor Summary

Constructors

Constructor	Description
KAFKAConstants()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

ZOOKEEPER_CONNECT

public static final String ZOOKEEPER_CONNECT

See Also:

• Constant Field Values

GROUP_ID

public static final String GROUP_ID

See Also:

• Constant Field Values

ZOOKEEPER_SESSION_TIMEOUT_MS

public static final String ZOOKEEPER_SESSION_TIMEOUT_MS

See Also:

• Constant Field Values

ZOOKEEPER_SYNC_TIME_MS

public static final String ZOOKEEPER_SYNC_TIME_MS

See Also:

• Constant Field Values

ZOOKEEPER_COMMIT_INTERVAL_MS

public static final String ZOOKEEPER_COMMIT_INTERVAL_MS

See Also:

• Constant Field Values

THREAD_COUNT

public static final String THREAD_COUNT

See Also:

• Constant Field Values

TOPICS

public static final String TOPICS

See Also:

• Constant Field Values

CONTENT_TYPE

public static final String CONTENT_TYPE

See Also:

• Constant Field Values

TOPIC_FILTER

public static final String TOPIC_FILTER

See Also:

• Constant Field Values

FILTER_FROM_WHITE_LIST

public static final String FILTER_FROM_WHITE_LIST

See Also:

• Constant Field Values

SIMPLE_TOPIC

public static final String SIMPLE_TOPIC

See Also:

• Constant Field Values

SIMPLE_BROKERS

public static final String SIMPLE_BROKERS

See Also:

• Constant Field Values

SIMPLE_PORT

public static final String SIMPLE_PORT

See Also:

• Constant Field Values

SIMPLE_PARTITION

public static final String SIMPLE_PARTITION

See Also:

• Constant Field Values

SIMPLE_MAX_MSG_TO_READ

public static final String SIMPLE_MAX_MSG_TO_READ

See Also:

• Constant Field Values

CONSUMER_TYPE

public static final String CONSUMER_TYPE

See Also:

• Constant Field Values

CONSUMER_TIMEOUT

public static final String CONSUMER_TIMEOUT

See Also:

• Constant Field Values

SO_TIMEOUT

public static final int SO_TIMEOUT

See Also:

• Constant Field Values

BUFFER_SIZE

public static final int BUFFER_SIZE

See Also:

• Constant Field Values

Constructor Details

KAFKAConstants

public KAFKAConstants()