Package io.smallrye.reactive.messaging.kafka

Class KafkaConnectorOutgoingConfiguration

    • Constructor Detail

      • KafkaConnectorOutgoingConfiguration

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

    • Method Detail

      • getKeySerializer

        public String getKeySerializer()
        Gets the key.serializer value from the configuration. Attribute Name: key.serializer Description: The serializer classname used to serialize the record's key Default Value: org.apache.kafka.common.serialization.StringSerializer
        Returns:
        the key.serializer

      • getValueSerializer

        public String getValueSerializer()
        Gets the value.serializer value from the configuration. Attribute Name: value.serializer Description: The serializer classname used to serialize the payload Mandatory: yes
        Returns:
        the value.serializer

      • getAcks

        public String getAcks()
        Gets the acks value from the configuration. Attribute Name: acks Description: The number of acknowledgments the producer requires the leader to have received before considering a request complete. This controls the durability of records that are sent. Accepted values are: 0, 1, all Default Value: 1
        Returns:
        the acks

      • getBufferMemory

        public Long getBufferMemory()
        Gets the buffer.memory value from the configuration. Attribute Name: buffer.memory Description: The total bytes of memory the producer can use to buffer records waiting to be sent to the server. Default Value: 33554432
        Returns:
        the buffer.memory

      • getRetries

        public Long getRetries()
        Gets the retries value from the configuration. Attribute Name: retries Description: Setting a value greater than zero will cause the client to resend any record whose send fails with a potentially transient error. Default Value: 2147483647
        Returns:
        the retries

      • getKey

        public Optional<String> getKey()
        Gets the key value from the configuration. Attribute Name: key Description: A key to used when writing the record
        Returns:
        the key

      • getPartition

        public Integer getPartition()
        Gets the partition value from the configuration. Attribute Name: partition Description: The target partition id. -1 to let the client determine the partition Default Value: -1
        Returns:
        the partition

      • getWaitForWriteCompletion

        public Boolean getWaitForWriteCompletion()
        Gets the waitForWriteCompletion value from the configuration. Attribute Name: waitForWriteCompletion Description: Whether the client waits for Kafka to acknowledge the written record before acknowledging the message Default Value: true
        Returns:
        the waitForWriteCompletion

      • getMaxInflightMessages

        public Integer getMaxInflightMessages()
        Gets the max-inflight-messages value from the configuration. Attribute Name: max-inflight-messages Description: The maximum number of messages to be written to Kafka concurrently - The default value is the value from the `max.in.flight.requests.per.connection` Kafka property. It configures the maximum number of unacknowledged requests the client before blocking. Note that if this setting is set to be greater than 1 and there are failed sends, there is a risk of message re-ordering due to retries. Default Value: 5
        Returns:
        the max-inflight-messages

      • getCloudEvents

        public Boolean getCloudEvents()
        Gets the cloud-events value from the configuration. Attribute Name: cloud-events Description: Enables (default) or disables the Cloud Event support. If enabled, the connector sends the outgoing messages as Cloud Event if the message to be sent includes Cloud Event Metadata. Default Value: true
        Returns:
        the cloud-events

      • getCloudEventsSource

        public Optional<String> getCloudEventsSource()
        Gets the cloud-events-source value from the configuration. Attribute Name: cloud-events-source Description: Configure the default `source` attribute of the outgoing Cloud Event. Requires `cloud-events` to be set to `true`. This value is used if the message does not configure the `source` attribute itself MicroProfile Config Alias: cloud-events-default-source
        Returns:
        the cloud-events-source

      • getCloudEventsType

        public Optional<String> getCloudEventsType()
        Gets the cloud-events-type value from the configuration. Attribute Name: cloud-events-type Description: Configure the default `type` attribute of the outgoing Cloud Event. Requires `cloud-events` to be set to `true`. This value is used if the message does not configure the `type` attribute itself MicroProfile Config Alias: cloud-events-default-type
        Returns:
        the cloud-events-type

      • getCloudEventsSubject

        public Optional<String> getCloudEventsSubject()
        Gets the cloud-events-subject value from the configuration. Attribute Name: cloud-events-subject Description: Configure the default `subject` attribute of the outgoing Cloud Event. Requires `cloud-events` to be set to `true`. This value is used if the message does not configure the `subject` attribute itself MicroProfile Config Alias: cloud-events-default-subject
        Returns:
        the cloud-events-subject

      • getCloudEventsDataContentType

        public Optional<String> getCloudEventsDataContentType()
        Gets the cloud-events-data-content-type value from the configuration. Attribute Name: cloud-events-data-content-type Description: Configure the default `datacontenttype` attribute of the outgoing Cloud Event. Requires `cloud-events` to be set to `true`. This value is used if the message does not configure the `datacontenttype` attribute itself MicroProfile Config Alias: cloud-events-default-data-content-type
        Returns:
        the cloud-events-data-content-type

      • getCloudEventsDataSchema

        public Optional<String> getCloudEventsDataSchema()
        Gets the cloud-events-data-schema value from the configuration. Attribute Name: cloud-events-data-schema Description: Configure the default `dataschema` attribute of the outgoing Cloud Event. Requires `cloud-events` to be set to `true`. This value is used if the message does not configure the `dataschema` attribute itself MicroProfile Config Alias: cloud-events-default-data-schema
        Returns:
        the cloud-events-data-schema

      • getCloudEventsInsertTimestamp

        public Boolean getCloudEventsInsertTimestamp()
        Gets the cloud-events-insert-timestamp value from the configuration. Attribute Name: cloud-events-insert-timestamp Description: Whether or not the connector should insert automatically the `time` attribute` into the outgoing Cloud Event. Requires `cloud-events` to be set to `true`. This value is used if the message does not configure the `time` attribute itself MicroProfile Config Alias: cloud-events-default-timestamp Default Value: true
        Returns:
        the cloud-events-insert-timestamp

      • getCloudEventsMode

        public String getCloudEventsMode()
        Gets the cloud-events-mode value from the configuration. Attribute Name: cloud-events-mode Description: The Cloud Event mode (`structured` or `binary` (default)). Indicates how are written the cloud events in the outgoing record Default Value: binary
        Returns:
        the cloud-events-mode