Package io.smallrye.reactive.messaging.kafka

Class KafkaConnectorIncomingConfiguration

    • Constructor Detail

      • KafkaConnectorIncomingConfiguration

        public KafkaConnectorIncomingConfiguration​(org.eclipse.microprofile.config.Config config)
        Creates a new KafkaConnectorIncomingConfiguration.

    • Method Detail

      • getTopics

        public Optional<String> getTopics()
        Gets the topics value from the configuration. Attribute Name: topics Description: A comma-separating list of topics to be consumed. Cannot be used with the `topic` or `pattern` properties
        Returns:
        the topics

      • getPattern

        public Boolean getPattern()
        Gets the pattern value from the configuration. Attribute Name: pattern Description: Indicate that the `topic` property is a regular expression. Must be used with the `topic` property. Cannot be used with the `topics` property Default Value: false
        Returns:
        the pattern

      • getKeyDeserializer

        public String getKeyDeserializer()
        Gets the key.deserializer value from the configuration. Attribute Name: key.deserializer Description: The deserializer classname used to deserialize the record's key Default Value: org.apache.kafka.common.serialization.StringDeserializer
        Returns:
        the key.deserializer

      • getValueDeserializer

        public String getValueDeserializer()
        Gets the value.deserializer value from the configuration. Attribute Name: value.deserializer Description: The deserializer classname used to deserialize the record's value Mandatory: yes
        Returns:
        the value.deserializer

      • getFetchMinBytes

        public Integer getFetchMinBytes()
        Gets the fetch.min.bytes value from the configuration. Attribute Name: fetch.min.bytes Description: The minimum amount of data the server should return for a fetch request. The default setting of 1 byte means that fetch requests are answered as soon as a single byte of data is available or the fetch request times out waiting for data to arrive. Default Value: 1
        Returns:
        the fetch.min.bytes

      • getGroupId

        public Optional<String> getGroupId()
        Gets the group.id value from the configuration. Attribute Name: group.id Description: A unique string that identifies the consumer group the application belongs to. If not set, a unique, generated id is used
        Returns:
        the group.id

      • getRetry

        public Boolean getRetry()
        Gets the retry value from the configuration. Attribute Name: retry Description: Whether or not the connection to the broker is re-attempted in case of failure Default Value: true
        Returns:
        the retry

      • getRetryAttempts

        public Integer getRetryAttempts()
        Gets the retry-attempts value from the configuration. Attribute Name: retry-attempts Description: The maximum number of reconnection before failing. -1 means infinite retry Default Value: -1
        Returns:
        the retry-attempts

      • getRetryMaxWait

        public Integer getRetryMaxWait()
        Gets the retry-max-wait value from the configuration. Attribute Name: retry-max-wait Description: The max delay (in seconds) between 2 reconnects Default Value: 30
        Returns:
        the retry-max-wait

      • getBroadcast

        public Boolean getBroadcast()
        Gets the broadcast value from the configuration. Attribute Name: broadcast Description: Whether the Kafka records should be dispatched to multiple consumer Default Value: false
        Returns:
        the broadcast

      • getAutoOffsetReset

        public String getAutoOffsetReset()
        Gets the auto.offset.reset value from the configuration. Attribute Name: auto.offset.reset Description: What to do when there is no initial offset in Kafka.Accepted values are earliest, latest and none Default Value: latest
        Returns:
        the auto.offset.reset

      • getFailureStrategy

        public String getFailureStrategy()
        Gets the failure-strategy value from the configuration. Attribute Name: failure-strategy Description: Specify the failure strategy to apply when a message produced from a record is nacked. Values can be `fail` (default), `ignore`, or `dead-letter-queue` Default Value: fail
        Returns:
        the failure-strategy

      • getDeadLetterQueueTopic

        public Optional<String> getDeadLetterQueueTopic()
        Gets the dead-letter-queue.topic value from the configuration. Attribute Name: dead-letter-queue.topic Description: When the `failure-strategy` is set to `dead-letter-queue` indicates on which topic the record is sent. Defaults is `dead-letter-topic-$channel`
        Returns:
        the dead-letter-queue.topic

      • getDeadLetterQueueKeySerializer

        public Optional<String> getDeadLetterQueueKeySerializer()
        Gets the dead-letter-queue.key.serializer value from the configuration. Attribute Name: dead-letter-queue.key.serializer Description: When the `failure-strategy` is set to `dead-letter-queue` indicates the key serializer to use. If not set the serializer associated to the key deserializer is used
        Returns:
        the dead-letter-queue.key.serializer

      • getDeadLetterQueueValueSerializer

        public Optional<String> getDeadLetterQueueValueSerializer()
        Gets the dead-letter-queue.value.serializer value from the configuration. Attribute Name: dead-letter-queue.value.serializer Description: When the `failure-strategy` is set to `dead-letter-queue` indicates the value serializer to use. If not set the serializer associated to the value deserializer is used
        Returns:
        the dead-letter-queue.value.serializer

      • getPartitions

        public Integer getPartitions()
        Gets the partitions value from the configuration. Attribute Name: partitions Description: The number of partitions to be consumed concurrently. The connector creates the specified amount of Kafka consumers. It should match the number of partition of the targetted topic Default Value: 1
        Returns:
        the partitions

      • getConsumerRebalanceListenerName

        public Optional<String> getConsumerRebalanceListenerName()
        Gets the consumer-rebalance-listener.name value from the configuration. Attribute Name: consumer-rebalance-listener.name Description: The name set in `javax.inject.Named` of a bean that implements `io.smallrye.reactive.messaging.kafka.KafkaConsumerRebalanceListener`. If set the listener will be applied to the consumer.
        Returns:
        the consumer-rebalance-listener.name