public class KafkaMessageDrivenChannelAdapterSpec<S extends KafkaMessageDrivenChannelAdapterSpec<S>> extends MessageProducerSpec<S,org.springframework.integration.kafka.inbound.KafkaMessageDrivenChannelAdapter>
MessageProducerSpec
implementation for the KafkaMessageDrivenChannelAdapter
.Modifier and Type | Class and Description |
---|---|
static class |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageDrivenChannelAdapterListenerContainerSpec
A
KafkaMessageListenerContainer configuration KafkaMessageDrivenChannelAdapterSpec
extension. |
static class |
KafkaMessageDrivenChannelAdapterSpec.KafkaMessageListenerContainerSpec
A helper class in the Builder pattern style to delegate options to the
KafkaMessageListenerContainer . |
id, logger, PARSER, target
Modifier and Type | Method and Description |
---|---|
S |
autoCommitOffset(boolean autoCommitOffset) |
S |
generateMessageId(boolean generateMessageId) |
S |
generateTimestamp(boolean generateTimestamp) |
<T> S |
keyDecoder(kafka.serializer.Decoder<T> keyDecoder)
Specify a
Decoder for Kafka message key. |
<T> S |
payloadDecoder(kafka.serializer.Decoder<T> payloadDecoder)
Specify a
Decoder for Kafka message body. |
S |
useMessageBuilderFactory(boolean useMessageBuilderFactory) |
autoStartup, doGet, errorChannel, id, outputChannel, phase
_this, get, getId
public <T> S keyDecoder(kafka.serializer.Decoder<T> keyDecoder)
Decoder
for Kafka message key.
Can be used as Java 8 Lambda.T
- the expected key type.keyDecoder
- the key decoder.public <T> S payloadDecoder(kafka.serializer.Decoder<T> payloadDecoder)
Decoder
for Kafka message body.
Can be used as Java 8 Lambda.T
- the expected payload type.payloadDecoder
- the value decoder.public S autoCommitOffset(boolean autoCommitOffset)
autoCommitOffset
- false to not auto-commit (default true).KafkaMessageDrivenChannelAdapter.setAutoCommitOffset(boolean)
public S generateMessageId(boolean generateMessageId)
generateMessageId
- true if a message id should be generated.KafkaMessageDrivenChannelAdapter.setGenerateMessageId(boolean)
public S generateTimestamp(boolean generateTimestamp)
generateTimestamp
- true if a timestamp should be generated.KafkaMessageDrivenChannelAdapter.setGenerateTimestamp(boolean)
public S useMessageBuilderFactory(boolean useMessageBuilderFactory)
useMessageBuilderFactory
- true if the MessageBuilderFactory
returned by
IntegrationObjectSupport.getMessageBuilderFactory()
should be used.KafkaMessageDrivenChannelAdapter.setUseMessageBuilderFactory(boolean)