K - the key type.V - the value type.public class KafkaInboundChannelAdapterSpec<K,V> extends org.springframework.integration.dsl.MessageSourceSpec<KafkaInboundChannelAdapterSpec<K,V>,KafkaMessageSource<K,V>>
| Modifier and Type | Method and Description |
|---|---|
KafkaInboundChannelAdapterSpec<K,V> |
clientId(java.lang.String clientId)
Deprecated.
in favor of using
ConsumerProperties |
KafkaInboundChannelAdapterSpec<K,V> |
groupId(java.lang.String groupId)
Deprecated.
in favor of using
ConsumerProperties |
KafkaInboundChannelAdapterSpec<K,V> |
messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
Set the message converter to replace the default.
|
KafkaInboundChannelAdapterSpec<K,V> |
payloadType(java.lang.Class<?> type)
Set the payload type.
|
KafkaInboundChannelAdapterSpec<K,V> |
pollTimeout(long pollTimeout)
Deprecated.
in favor of using
ConsumerProperties |
KafkaInboundChannelAdapterSpec<K,V> |
rawMessageHeader(boolean rawMessageHeader)
Set to true to include the raw
ConsumerRecord as headers with keys
KafkaHeaders.RAW_DATA and
IntegrationMessageHeaderAccessor.SOURCE_DATA. |
KafkaInboundChannelAdapterSpec<K,V> |
rebalanceListener(org.apache.kafka.clients.consumer.ConsumerRebalanceListener rebalanceListener)
Deprecated.
in favor of using
ConsumerProperties |
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop@Deprecated public KafkaInboundChannelAdapterSpec<K,V> groupId(java.lang.String groupId)
ConsumerPropertiesgroupId - the group id.ConsumerProperties@Deprecated public KafkaInboundChannelAdapterSpec<K,V> clientId(java.lang.String clientId)
ConsumerPropertiesclientId - the client id.ConsumerProperties@Deprecated public KafkaInboundChannelAdapterSpec<K,V> pollTimeout(long pollTimeout)
ConsumerPropertiespollTimeout - the poll timeout.ConsumerPropertiespublic KafkaInboundChannelAdapterSpec<K,V> messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
MessagingMessageConverter.messageConverter - the converter.public KafkaInboundChannelAdapterSpec<K,V> payloadType(java.lang.Class<?> type)
type - the type to convert to.@Deprecated public KafkaInboundChannelAdapterSpec<K,V> rebalanceListener(org.apache.kafka.clients.consumer.ConsumerRebalanceListener rebalanceListener)
ConsumerPropertiesrebalanceListener - the rebalance listener.ConsumerPropertiespublic KafkaInboundChannelAdapterSpec<K,V> rawMessageHeader(boolean rawMessageHeader)
ConsumerRecord as headers with keys
KafkaHeaders.RAW_DATA and
IntegrationMessageHeaderAccessor.SOURCE_DATA. enabling callers to have
access to the record to process errors.rawMessageHeader - true to include the header.