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)
ConsumerProperties
groupId
- the group id.ConsumerProperties
@Deprecated public KafkaInboundChannelAdapterSpec<K,V> clientId(java.lang.String clientId)
ConsumerProperties
clientId
- the client id.ConsumerProperties
@Deprecated public KafkaInboundChannelAdapterSpec<K,V> pollTimeout(long pollTimeout)
ConsumerProperties
pollTimeout
- the poll timeout.ConsumerProperties
public 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)
ConsumerProperties
rebalanceListener
- the rebalance listener.ConsumerProperties
public 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.