public interface KafkaRpcConstants
Modifier and Type | Field and Description |
---|---|
static long |
DEFAULT_TTL |
static long |
DEFAULT_TTL_CONFIGURED |
static String |
DEFAULT_TTL_PROPERTY |
static String |
KAFKA_CONFIG_PID |
static String |
KAFKA_CONFIG_SYS_PROP_PREFIX |
static Integer |
MAX_BUFFER_SIZE |
static int |
MAX_BUFFER_SIZE_CONFIGURED |
static String |
MAX_BUFFER_SIZE_PROPERTY |
static String |
RPC_REQUEST_TOPIC_NAME |
static String |
RPC_RESPONSE_TOPIC_NAME |
static String |
RPC_TOPIC_PREFIX |
Modifier and Type | Method and Description |
---|---|
static int |
getBufferSize(int messageSize,
int maxBufferSize,
int chunk) |
static int |
getMaxBufferSize(Properties properties) |
static final String KAFKA_CONFIG_PID
static final String KAFKA_CONFIG_SYS_PROP_PREFIX
static final String RPC_TOPIC_PREFIX
static final String RPC_REQUEST_TOPIC_NAME
static final String RPC_RESPONSE_TOPIC_NAME
static final int MAX_BUFFER_SIZE_CONFIGURED
static final String MAX_BUFFER_SIZE_PROPERTY
static final Integer MAX_BUFFER_SIZE
static final long DEFAULT_TTL_CONFIGURED
static final String DEFAULT_TTL_PROPERTY
static final long DEFAULT_TTL
static int getBufferSize(int messageSize, int maxBufferSize, int chunk)
static int getMaxBufferSize(Properties properties)
Copyright © 2020. All rights reserved.