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
static long	DEFAULT_TTL_CONFIGURED
static java.lang.String	DEFAULT_TTL_PROPERTY
static java.lang.String	KAFKA_RPC_CONFIG_PID
static java.lang.String	KAFKA_RPC_CONFIG_SYS_PROP_PREFIX
static java.lang.Integer	MAX_BUFFER_SIZE
static int	MAX_BUFFER_SIZE_CONFIGURED
static java.lang.String	MAX_BUFFER_SIZE_PROPERTY
static int	MAX_CONCURRENT_CALLS
static java.lang.String	MAX_CONCURRENT_CALLS_PROPERTY
static java.lang.String	MAX_DURATION_BULK_HEAD
static int	MAX_WAIT_DURATION_BULK_HEAD
static java.lang.String	RPC_REQUEST_TOPIC_NAME
static java.lang.String	RPC_RESPONSE_TOPIC_NAME
static java.lang.String	RPC_TOPIC_PREFIX
static java.lang.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(java.util.Properties properties)

Field Detail

KAFKA_RPC_CONFIG_PID

static final java.lang.String KAFKA_RPC_CONFIG_PID

See Also:

Constant Field Values

KAFKA_RPC_CONFIG_SYS_PROP_PREFIX

static final java.lang.String KAFKA_RPC_CONFIG_SYS_PROP_PREFIX

See Also:

Constant Field Values

RPC_TOPIC_PREFIX

static final java.lang.String RPC_TOPIC_PREFIX

See Also:

Constant Field Values

RPC_REQUEST_TOPIC_NAME

static final java.lang.String RPC_REQUEST_TOPIC_NAME

See Also:

Constant Field Values

RPC_RESPONSE_TOPIC_NAME

static final java.lang.String RPC_RESPONSE_TOPIC_NAME

See Also:

Constant Field Values

SINGLE_TOPIC_FOR_ALL_MODULES

static final java.lang.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 java.lang.String MAX_BUFFER_SIZE_PROPERTY

See Also:

Constant Field Values

MAX_CONCURRENT_CALLS_PROPERTY

static final java.lang.String MAX_CONCURRENT_CALLS_PROPERTY

See Also:

Constant Field Values

MAX_DURATION_BULK_HEAD

static final java.lang.String MAX_DURATION_BULK_HEAD

See Also:

Constant Field Values

MAX_BUFFER_SIZE

static final java.lang.Integer MAX_BUFFER_SIZE

DEFAULT_TTL_CONFIGURED

static final long DEFAULT_TTL_CONFIGURED

See Also:

Constant Field Values

DEFAULT_TTL_PROPERTY

static final java.lang.String DEFAULT_TTL_PROPERTY

See Also:

Constant Field Values

DEFAULT_TTL

static final long DEFAULT_TTL

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(java.util.Properties properties)