Class KafkaMessageSource.KafkaAckInfoImpl
java.lang.Object
org.springframework.integration.kafka.inbound.KafkaMessageSource.KafkaAckInfoImpl
- All Implemented Interfaces:
java.lang.Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>,KafkaMessageSource.KafkaAckInfo<K,V>
- Enclosing class:
- KafkaMessageSource<K,V>
public class KafkaMessageSource.KafkaAckInfoImpl extends java.lang.Object implements KafkaMessageSource.KafkaAckInfo<K,V>
Information for building an KafkaAckCallback.
-
Method Summary
Modifier and Type Method Description intcompareTo(KafkaMessageSource.KafkaAckInfo<K,V> other)org.apache.kafka.clients.consumer.Consumer<K,V>getConsumer()java.lang.ObjectgetConsumerMonitor()java.lang.StringgetGroupId()java.util.Map<org.apache.kafka.common.TopicPartition,java.util.Set<KafkaMessageSource.KafkaAckInfo<K,V>>>getOffsets()org.apache.kafka.clients.consumer.ConsumerRecord<K,V>getRecord()org.apache.kafka.common.TopicPartitiongetTopicPartition()booleanisAckDeferred()booleanisRolledBack()voidsetAckDeferred(boolean ackDeferred)voidsetRolledBack(boolean rolledBack)java.lang.StringtoString()
-
Method Details
-
getConsumerMonitor
public java.lang.Object getConsumerMonitor()- Specified by:
getConsumerMonitorin interfaceKafkaMessageSource.KafkaAckInfo<K,V>
-
getGroupId
public java.lang.String getGroupId()- Specified by:
getGroupIdin interfaceKafkaMessageSource.KafkaAckInfo<K,V>
-
getConsumer
- Specified by:
getConsumerin interfaceKafkaMessageSource.KafkaAckInfo<K,V>
-
getRecord
- Specified by:
getRecordin interfaceKafkaMessageSource.KafkaAckInfo<K,V>
-
getTopicPartition
public org.apache.kafka.common.TopicPartition getTopicPartition()- Specified by:
getTopicPartitionin interfaceKafkaMessageSource.KafkaAckInfo<K,V>
-
getOffsets
public java.util.Map<org.apache.kafka.common.TopicPartition,java.util.Set<KafkaMessageSource.KafkaAckInfo<K,V>>> getOffsets()- Specified by:
getOffsetsin interfaceKafkaMessageSource.KafkaAckInfo<K,V>
-
isRolledBack
public boolean isRolledBack()- Specified by:
isRolledBackin interfaceKafkaMessageSource.KafkaAckInfo<K,V>
-
setRolledBack
public void setRolledBack(boolean rolledBack)- Specified by:
setRolledBackin interfaceKafkaMessageSource.KafkaAckInfo<K,V>
-
isAckDeferred
public boolean isAckDeferred()- Specified by:
isAckDeferredin interfaceKafkaMessageSource.KafkaAckInfo<K,V>
-
setAckDeferred
public void setAckDeferred(boolean ackDeferred)- Specified by:
setAckDeferredin interfaceKafkaMessageSource.KafkaAckInfo<K,V>
-
compareTo
- Specified by:
compareToin interfacejava.lang.Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>
-
toString
public java.lang.String toString()- Overrides:
toStringin classjava.lang.Object
-