Package org.odpi.openmetadata.adapters.eventbus.topic.kafka

Enum Class KafkaOpenMetadataEventConsumerProperty

java.lang.Object

java.lang.Enum<KafkaOpenMetadataEventConsumerProperty>

org.odpi.openmetadata.adapters.eventbus.topic.kafka.KafkaOpenMetadataEventConsumerProperty

All Implemented Interfaces:

Serializable, Comparable<KafkaOpenMetadataEventConsumerProperty>, Constable

public enum KafkaOpenMetadataEventConsumerProperty
extends Enum<KafkaOpenMetadataEventConsumerProperty>

Configurable properties for the KafkaOpenMetadataEventConsumer

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Enum

Enum.EnumDesc<E extends Enum<E>>

Enum Constant Summary

Enum Constants

Enum Constant	Description
COMMIT_CHECK_INTERVAL_MS	Controls the interval between checks to see if a message has been processed and its offset committed to Kafka.
CONSUMER_EVENT_PROCESSING_TIMEOUT_MINS	This property adds an optional upper bound for the consumer event processing before an event is treated as being fully processed and committed to Kafka.
CONSUMER_TIMEOUT_PREVENTION_SAFETY_WINDOW_MS
MAX_QUEUE_SIZE
POLL_TIMEOUT
RECOVERY_SLEEP_TIME

Method Summary

Modifier and Type	Method	Description
String	getDefaultValue()
String	getPropertyName()
static KafkaOpenMetadataEventConsumerProperty	valueOf(String name)	Returns the enum constant of this class with the specified name.
static KafkaOpenMetadataEventConsumerProperty[]	values()	Returns an array containing the constants of this enum class, in the order they are declared.

Methods inherited from class java.lang.Enum

clone, compareTo, describeConstable, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Details

MAX_QUEUE_SIZE

public static final KafkaOpenMetadataEventConsumerProperty MAX_QUEUE_SIZE

CONSUMER_TIMEOUT_PREVENTION_SAFETY_WINDOW_MS

public static final KafkaOpenMetadataEventConsumerProperty CONSUMER_TIMEOUT_PREVENTION_SAFETY_WINDOW_MS

POLL_TIMEOUT

public static final KafkaOpenMetadataEventConsumerProperty POLL_TIMEOUT

RECOVERY_SLEEP_TIME

public static final KafkaOpenMetadataEventConsumerProperty RECOVERY_SLEEP_TIME

CONSUMER_EVENT_PROCESSING_TIMEOUT_MINS

public static final KafkaOpenMetadataEventConsumerProperty CONSUMER_EVENT_PROCESSING_TIMEOUT_MINS

This property adds an optional upper bound for the consumer event processing before an event is treated as being fully processed and committed to Kafka. If the value is negative, there is no timeout, and offsets will not be committed into Kafka until the message has been completely processed by all consumers. This property is only used if auto commit is disabled in the Kafka consumer.

COMMIT_CHECK_INTERVAL_MS

public static final KafkaOpenMetadataEventConsumerProperty COMMIT_CHECK_INTERVAL_MS

Controls the interval between checks to see if a message has been processed and its offset committed to Kafka. This is only used if auto commit is disabled in the Kafka consumer.

Method Details

values

public static KafkaOpenMetadataEventConsumerProperty[] values()

Returns an array containing the constants of this enum class, in the order they are declared.

Returns:

an array containing the constants of this enum class, in the order they are declared

valueOf

public static KafkaOpenMetadataEventConsumerProperty valueOf(String name)

Returns the enum constant of this class with the specified name. The string must match exactly an identifier used to declare an enum constant in this class. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

IllegalArgumentException - if this enum class has no constant with the specified name

NullPointerException - if the argument is null

getPropertyName

public String getPropertyName()

getDefaultValue

public String getDefaultValue()