public interface KafkaSinkConstants
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MAX_BUFFER_SIZE |
static String |
DEFAULT_MESSAGEID_CONFIG |
static String |
KAFKA_CONFIG_CONSUMER_PID |
static String |
KAFKA_CONFIG_PID |
static String |
KAFKA_CONFIG_SYS_PROP_PREFIX |
static String |
KAFKA_TOPIC_PREFIX |
static String |
MAX_BUFFER_SIZE_PROPERTY |
static String |
MESSAGEID_CACHE_CONFIG |
static final String KAFKA_TOPIC_PREFIX
static final String KAFKA_CONFIG_PID
static final String KAFKA_CONFIG_CONSUMER_PID
static final String KAFKA_CONFIG_SYS_PROP_PREFIX
static final String MAX_BUFFER_SIZE_PROPERTY
static final int DEFAULT_MAX_BUFFER_SIZE
static final String MESSAGEID_CACHE_CONFIG
static final String DEFAULT_MESSAGEID_CONFIG
Copyright © 2020. All rights reserved.