The topic configured by this configuration.
Custom implementation of a Kafka Encoder for encoding message values.
Custom implementation of a Kafka Encoder for encoding message keys.
Class type used for the key
Class type used for the value
Custom Kafka key partitioner.
Indicates if this producer is async or not.
number of messages to batch at this producer.
Kafka producer properties to use for all producers
Regex pattern to match topic
Custom implementation of a Kafka Decoder for values.
Custom implementation of a Kafka Decoder for keys.
A java.util.concurrent.Executor bean reference.
Typically
org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor.
Used to execute iterator task on KafkaStreams.
Kafka Server Bean Name
Kafka consumer properties to use for all consumers
The definition for the Spring Integration Kafka
Inbound Channel Adapter.
Maximum amount of time in milliseconds to wait when sending a message to the channel
if such channel may block. For example, a Queue Channel can block until space is available
if its maximum capacity has been reached.
Kafka consumer context reference.
Defines kafka outbound channel adapter that writes the contents of the
Message to kafka broker.
Kafka producer context reference.
Specifies the order for invocation when this endpoint is connected as a
subscriber to a SubscribableChannel.
The definition for the Spring Integration Kafka
KafkaMessageDrivenChannelAdapter.
Maximum amount of time in milliseconds to wait when sending a message to the channel
if such channel may block. For example, a Queue Channel can block until space is available
if its maximum capacity has been reached.
Message Channel to which error Messages should be sent.
A 'kafka.serializer.Decoder' bean reference for decoding the 'key'
of the received the 'kafka.message.Message'. Defaults to 'kafka.serializer.DefaultDecoder'
without 'kafka.utils.VerifiableProperties'.
A 'kafka.serializer.Decoder' bean reference for decoding the 'payload'
of the received the 'kafka.message.Message'. Defaults to 'kafka.serializer.DefaultDecoder'
without 'kafka.utils.VerifiableProperties'.
A 'org.springframework.integration.kafka.listener.KafkaMessageListenerContainer' bean reference.
Mutually exclusive with 'connection-factory', 'topics', 'offset-manager', 'error-handler',
'task-executor', 'concurrency', 'stop-timeout', 'max-fetch', 'queue-size'.
A 'org.springframework.integration.kafka.core.ConnectionFactory' bean reference.
Mutually exclusive with 'listener-container'.
The comma-separated Kafka topics to listen to.
Mutually exclusive with 'listener-container'.
A 'org.springframework.integration.kafka.listener.OffsetManager' bean reference.
Defaults to 'org.springframework.integration.kafka.listener.MetadataStoreOffsetManager'.
Mutually exclusive with 'listener-container'.
A 'org.springframework.integration.kafka.listener.ErrorHandler' bean reference.
Used from 'org.springframework.integration.kafka.listener.KafkaMessageListenerContainer'
to handle errors from 'kafka.message.Message' decoding and when the 'error-channel'
isn't provided to catch message producing errors.
Defaults to 'org.springframework.integration.kafka.listener.LoggingErrorHandler.
Mutually exclusive with 'listener-container'.
A 'java.util.concurrent.Executor' bean reference to fetch messages from Kafka.
Defaults to the 'ThreadPoolExecutor' with the pool based on the number of 'partitionsByBroker'.
Mutually exclusive with 'listener-container'.
The number of internal concurrent
'org.springframework.integration.kafka.listener.QueueingMessageListenerInvoker'.
Defaults to '1'.
Mutually exclusive with 'listener-container'.
The maximum amount of time (in milliseconds) to wait for each 'org.springframework.integration.kafka.listener.QueueingMessageListenerInvoker' to finish before stopping.
Defaults to '1000'.
Mutually exclusive with 'listener-container'.
The maximum amount of data (in bytes) that pollers will fetch in one round.
Defaults to '300 * 1024'.
Mutually exclusive with 'listener-container'.
The maximum number of messages that are buffered by each concurrent 'MessageListener' runner.
Increasing the value may increase throughput, but also increases the memory consumption.
Defaults to '1024'.
Mutually exclusive with 'listener-container'.
When 'true', the adapter automatically commits the offset. When 'false', the adapter
inserts a 'kafka_acknowledgment` header allowing the user to manually commit the offset
using the `Acknowledgment.acknowledge()` method. Default 'true'.
When 'true', use the configured message builder from the integration application context
(bean:"messageBuilderFactory", which defaults to a "DefaultMessageBuilderFactory").
When 'false', use an internal, optimized, message creation algorithm. Default 'false'.
When 'true', generate a unique ID header for each new message.
Default 'false'. Set to `true` if messages contain collections and you use a splitter
later in the flow, or a router where a message is sent to multiple recipients with
'apply-sequence' set to 'true'. In this cases, the message id is used as the correlation
id of the resulting messages. If 'use-context-message-builder' is 'true', this
setting may be ignored by the configured message builder factory (this is the case
for the 'DefaultMessageBuilderFactory', where an ID is always generated).
When 'true', generate a TIMESTAMP header for each new message.
Default 'false' (TIMESTAMP header is set to -1).
If 'use-context-message-builder' is 'true', this
setting may be ignored by the configured message builder factory (this is the case
for the 'DefaultMessageBuilderFactory', where a timestamp header is always generated).