Enum Class KafkaOpenMetadataEventConsumerProperty

All Implemented Interfaces:
Serializable, Comparable<KafkaOpenMetadataEventConsumerProperty>, Constable

public enum KafkaOpenMetadataEventConsumerProperty extends Enum<KafkaOpenMetadataEventConsumerProperty>
Configurable properties for the KafkaOpenMetadataEventConsumer
  • Enum Constant Details


      public static final KafkaOpenMetadataEventConsumerProperty MAX_QUEUE_SIZE

      public static final KafkaOpenMetadataEventConsumerProperty CONSUMER_TIMEOUT_PREVENTION_SAFETY_WINDOW_MS

      public static final KafkaOpenMetadataEventConsumerProperty POLL_TIMEOUT

      public static final KafkaOpenMetadataEventConsumerProperty RECOVERY_SLEEP_TIME

      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.

      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.
      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.)
      name - the name of the enum constant to be returned.
      the enum constant with the specified name
      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()