Package org.opennms.core.ipc.common.kafka

Interface KafkaRpcConstants

public interface KafkaRpcConstants

This handles all the configuration specific to RPC and some utils common to OpenNMS/Minion.

Field Summary

Fields

Modifier and Type	Field	Description
static long	DEFAULT_TTL_CONFIGURED
static String	DEFAULT_TTL_PROPERTY
static String	KAFKA_IPC_CONFIG_PID
static String	KAFKA_IPC_CONFIG_SYS_PROP_PREFIX
static String	KAFKA_RPC_CONFIG_PID
static String	KAFKA_RPC_CONFIG_SYS_PROP_PREFIX
static org.slf4j.Logger	LOG
static int	MAX_BUFFER_SIZE_CONFIGURED
static String	MAX_BUFFER_SIZE_PROPERTY
static int	MAX_CONCURRENT_CALLS
static String	MAX_CONCURRENT_CALLS_PROPERTY
static String	MAX_DURATION_BULK_HEAD
static int	MAX_WAIT_DURATION_BULK_HEAD
static String	RPC_REQUEST_TOPIC_NAME
static String	RPC_RESPONSE_TOPIC_NAME
static String	RPC_TOPIC_PREFIX
static String	SINGLE_TOPIC_FOR_ALL_MODULES

Method Summary

Static Methods

Modifier and Type	Method	Description
static int	getBufferSize(int messageSize, int maxBufferSize, int chunk)
static int	getMaxBufferSize(Properties properties)

Field Detail

LOG

static final org.slf4j.Logger LOG

KAFKA_RPC_CONFIG_PID

static final String KAFKA_RPC_CONFIG_PID

See Also:

Constant Field Values

KAFKA_IPC_CONFIG_PID

static final String KAFKA_IPC_CONFIG_PID

See Also:

Constant Field Values

KAFKA_RPC_CONFIG_SYS_PROP_PREFIX

static final String KAFKA_RPC_CONFIG_SYS_PROP_PREFIX

See Also:

Constant Field Values

KAFKA_IPC_CONFIG_SYS_PROP_PREFIX

static final String KAFKA_IPC_CONFIG_SYS_PROP_PREFIX

See Also:

Constant Field Values

RPC_TOPIC_PREFIX

static final String RPC_TOPIC_PREFIX

See Also:

Constant Field Values

RPC_REQUEST_TOPIC_NAME

static final String RPC_REQUEST_TOPIC_NAME

See Also:

Constant Field Values

RPC_RESPONSE_TOPIC_NAME

static final String RPC_RESPONSE_TOPIC_NAME

See Also:

Constant Field Values

SINGLE_TOPIC_FOR_ALL_MODULES

static final String SINGLE_TOPIC_FOR_ALL_MODULES

See Also:

Constant Field Values

MAX_BUFFER_SIZE_CONFIGURED

static final int MAX_BUFFER_SIZE_CONFIGURED

See Also:

Constant Field Values

MAX_BUFFER_SIZE_PROPERTY

static final String MAX_BUFFER_SIZE_PROPERTY

See Also:

Constant Field Values

MAX_CONCURRENT_CALLS_PROPERTY

static final String MAX_CONCURRENT_CALLS_PROPERTY

See Also:

Constant Field Values

MAX_DURATION_BULK_HEAD

static final String MAX_DURATION_BULK_HEAD

See Also:

Constant Field Values

DEFAULT_TTL_CONFIGURED

static final long DEFAULT_TTL_CONFIGURED

See Also:

Constant Field Values

DEFAULT_TTL_PROPERTY

static final String DEFAULT_TTL_PROPERTY

See Also:

Constant Field Values

MAX_CONCURRENT_CALLS

static final int MAX_CONCURRENT_CALLS

See Also:

Constant Field Values

MAX_WAIT_DURATION_BULK_HEAD

static final int MAX_WAIT_DURATION_BULK_HEAD

See Also:

Constant Field Values

Method Detail

getBufferSize

static int getBufferSize(int messageSize,
                         int maxBufferSize,
                         int chunk)

getMaxBufferSize

static int getMaxBufferSize(Properties properties)