Class KafkaMessageSource.KafkaAckInfoImpl

java.lang.Object

org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckInfoImpl

All Implemented Interfaces:

Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>, KafkaMessageSource.KafkaAckInfo<K,V>

Enclosing class:

KafkaMessageSource<K,V>

public class KafkaMessageSource.KafkaAckInfoImpl
extends Object
implements KafkaMessageSource.KafkaAckInfo<K,V>

Information for building an KafkaAckCallback.

Since:

5.4

Author:

Gary Russell, Mark Norkin, Artem Bilan, Anshul Mehra, Christian Tzolov

Method Summary

Modifier and Type	Method	Description
int	compareTo(KafkaMessageSource.KafkaAckInfo<K,V> other)
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)
String	toString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Details

getConsumerMonitor

public Object getConsumerMonitor()

Specified by:

getConsumerMonitor in interface KafkaMessageSource.KafkaAckInfo<K,V>

getGroupId

public String getGroupId()

Specified by:

getGroupId in interface KafkaMessageSource.KafkaAckInfo<K,V>

getConsumer

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

Specified by:

getConsumer in interface KafkaMessageSource.KafkaAckInfo<K,V>

getRecord

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

Specified by:

getRecord in interface KafkaMessageSource.KafkaAckInfo<K,V>

getTopicPartition

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

Specified by:

getTopicPartition in interface KafkaMessageSource.KafkaAckInfo<K,V>

getOffsets

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

Specified by:

getOffsets in interface KafkaMessageSource.KafkaAckInfo<K,V>

isRolledBack

public boolean isRolledBack()

Specified by:

isRolledBack in interface KafkaMessageSource.KafkaAckInfo<K,V>

setRolledBack

public void setRolledBack(boolean rolledBack)

Specified by:

setRolledBack in interface KafkaMessageSource.KafkaAckInfo<K,V>

isAckDeferred

public boolean isAckDeferred()

Specified by:

isAckDeferred in interface KafkaMessageSource.KafkaAckInfo<K,V>

setAckDeferred

public void setAckDeferred(boolean ackDeferred)

Specified by:

setAckDeferred in interface KafkaMessageSource.KafkaAckInfo<K,V>

compareTo

public int compareTo(KafkaMessageSource.KafkaAckInfo<K,V> other)

Specified by:

compareTo in interface Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>

toString

public String toString()

Overrides:

toString in class Object