org.springframework.integration.kafka.inbound

Interface KafkaMessageSource.KafkaAckInfo<K,V>

Type Parameters:

K - the key type.

V - the value type.

All Superinterfaces:

Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>

All Known Implementing Classes:

KafkaMessageSource.KafkaAckInfoImpl

Enclosing class:

KafkaMessageSource<K,V>

public static interface KafkaMessageSource.KafkaAckInfo<K,V>
extends Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>

Information for building an KafkaAckCallback.

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.clients.consumer.Consumer<K,V>	getConsumer()
Object	getConsumerMonitor()
String	getGroupId()
Map<org.apache.kafka.common.TopicPartition,Set<KafkaMessageSource.KafkaAckInfo<K,V>>>	getOffsets()
org.apache.kafka.clients.consumer.ConsumerRecord<K,V>	getRecord()
org.apache.kafka.common.TopicPartition	getTopicPartition()
boolean	isAckDeferred()
boolean	isRolledBack()
void	setAckDeferred(boolean ackDeferred)
void	setRolledBack(boolean rolledBack)

Methods inherited from interface java.lang.Comparable

compareTo

Method Detail

getConsumerMonitor

Object getConsumerMonitor()

getGroupId

String getGroupId()

getConsumer

org.apache.kafka.clients.consumer.Consumer<K,V> getConsumer()

getRecord

org.apache.kafka.clients.consumer.ConsumerRecord<K,V> getRecord()

getTopicPartition

org.apache.kafka.common.TopicPartition getTopicPartition()

getOffsets

Map<org.apache.kafka.common.TopicPartition,Set<KafkaMessageSource.KafkaAckInfo<K,V>>> getOffsets()

isRolledBack

boolean isRolledBack()

setRolledBack

void setRolledBack(boolean rolledBack)

isAckDeferred

boolean isAckDeferred()

setAckDeferred

void setAckDeferred(boolean ackDeferred)