Interface KafkaMessageSource.KafkaAckInfo<K,V>
- Type Parameters:
K- the key type.V- the value type.
- All Superinterfaces:
java.lang.Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>
- All Known Implementing Classes:
KafkaMessageSource.KafkaAckInfoImpl
- Enclosing class:
- KafkaMessageSource<K,V>
public static interface KafkaMessageSource.KafkaAckInfo<K,V> extends java.lang.Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>
Information for building an KafkaAckCallback.
-
Method Summary
Modifier and Type Method Description 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)
-
Method Details
-
getConsumerMonitor
java.lang.Object getConsumerMonitor() -
getGroupId
java.lang.String getGroupId() -
getConsumer
-
getRecord
-
getTopicPartition
org.apache.kafka.common.TopicPartition getTopicPartition() -
getOffsets
java.util.Map<org.apache.kafka.common.TopicPartition,java.util.Set<KafkaMessageSource.KafkaAckInfo<K,V>>> getOffsets() -
isRolledBack
boolean isRolledBack() -
setRolledBack
void setRolledBack(boolean rolledBack) -
isAckDeferred
boolean isAckDeferred() -
setAckDeferred
void setAckDeferred(boolean ackDeferred)
-