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) |
KafkaInboundChannelAdapterSpec<K,V> |
groupId(java.lang.String groupId) |
KafkaInboundChannelAdapterSpec<K,V> |
messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter) |
KafkaInboundChannelAdapterSpec<K,V> |
payloadType(java.lang.Class<?> type) |
KafkaInboundChannelAdapterSpec<K,V> |
pollTimeout(long pollTimeout) |
KafkaInboundChannelAdapterSpec<K,V> |
rawMessageHeader(boolean rawMessageHeader) |
KafkaInboundChannelAdapterSpec<K,V> |
rebalanceListener(org.apache.kafka.clients.consumer.ConsumerRebalanceListener rebalanceListener) |
_this, createInstance, destroyInstance, doGet, get, getId, getObjectType, getPhase, id, isAutoStartup, isRunning, start, stop, stop
public KafkaInboundChannelAdapterSpec<K,V> groupId(java.lang.String groupId)
public KafkaInboundChannelAdapterSpec<K,V> clientId(java.lang.String clientId)
public KafkaInboundChannelAdapterSpec<K,V> pollTimeout(long pollTimeout)
public KafkaInboundChannelAdapterSpec<K,V> messageConverter(org.springframework.kafka.support.converter.RecordMessageConverter messageConverter)
public KafkaInboundChannelAdapterSpec<K,V> payloadType(java.lang.Class<?> type)
public KafkaInboundChannelAdapterSpec<K,V> rebalanceListener(org.apache.kafka.clients.consumer.ConsumerRebalanceListener rebalanceListener)
public KafkaInboundChannelAdapterSpec<K,V> rawMessageHeader(boolean rawMessageHeader)