Interface KafkaSinkConstants
-
public interface KafkaSinkConstants
-
-
Field Summary
Fields Modifier and Type Field Description static int
DEFAULT_MAX_BUFFER_SIZE
static java.lang.String
DEFAULT_MESSAGEID_CONFIG
static java.lang.String
KAFKA_CONFIG_CONSUMER_PID
static java.lang.String
KAFKA_CONFIG_PID
static java.lang.String
KAFKA_CONFIG_SYS_PROP_PREFIX
static java.lang.String
KAFKA_TOPIC_PREFIX
static java.lang.String
MAX_BUFFER_SIZE_PROPERTY
static java.lang.String
MESSAGEID_CACHE_CONFIG
-
-
-
Field Detail
-
KAFKA_TOPIC_PREFIX
static final java.lang.String KAFKA_TOPIC_PREFIX
- See Also:
- Constant Field Values
-
KAFKA_CONFIG_PID
static final java.lang.String KAFKA_CONFIG_PID
- See Also:
- Constant Field Values
-
KAFKA_CONFIG_CONSUMER_PID
static final java.lang.String KAFKA_CONFIG_CONSUMER_PID
- See Also:
- Constant Field Values
-
KAFKA_CONFIG_SYS_PROP_PREFIX
static final java.lang.String KAFKA_CONFIG_SYS_PROP_PREFIX
- See Also:
- Constant Field Values
-
MAX_BUFFER_SIZE_PROPERTY
static final java.lang.String MAX_BUFFER_SIZE_PROPERTY
- See Also:
- Constant Field Values
-
DEFAULT_MAX_BUFFER_SIZE
static final int DEFAULT_MAX_BUFFER_SIZE
- See Also:
- Constant Field Values
-
MESSAGEID_CACHE_CONFIG
static final java.lang.String MESSAGEID_CACHE_CONFIG
- See Also:
- Constant Field Values
-
DEFAULT_MESSAGEID_CONFIG
static final java.lang.String DEFAULT_MESSAGEID_CONFIG
- See Also:
- Constant Field Values
-
-