Defines the Consumer Endpoint for the KafkaProducerMessageHandler
that writes the contents of the Message to kafka broker.
Specifies a timeout in milliseconds for how long the 'KafkaProducerMessageHandler'
should wait wait for send operation results. Defaults to 10 seconds.
The timeout is applied only in 'sync' mode.
Specifies an expression that is evaluated to determine a timeout in milliseconds
for how long the 'KafkaProducerMessageHandler'
should wait wait for send operation results. Defaults to 10 seconds.
The timeout is applied only in 'sync' mode.
Specifies the order for invocation when this endpoint is connected as a
subscriber to a SubscribableChannel.
Defines the Message Producing Endpoint for the 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.
An 'org.springframework.kafka.listener.AbstractMessageListenerContainer' bean reference.
An 'org.springframework.kafka.support.converter.MessageConverter' bean reference.
if mode = 'record' must be a 'RecordMessageConverter'; if mode = 'batch' must be
a `BatchMessageConverter`. Defaults to the default implementation for each mode.
'record' or 'batch' - default 'record' - one converted ConsumerRecord per message, when
'batch' then the payload is a collection of converted ConsumerRecords.
Set the payload type to convert to when using a type-aware message converter such as the
StringJsonMessageConverter. Fully qualified class name; defaults to 'java.lang.Object'.