K
- the key type.V
- the value type.public static interface KafkaMessageSource.KafkaAckInfo<K,V> extends java.lang.Comparable<KafkaMessageSource.KafkaAckInfo<K,V>>
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.consumer.Consumer<K,V> |
getConsumer() |
java.lang.Object |
getConsumerMonitor() |
java.lang.String |
getGroupId() |
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.TopicPartition |
getTopicPartition() |
boolean |
isAckDeferred() |
boolean |
isRolledBack() |
void |
setAckDeferred(boolean ackDeferred) |
void |
setRolledBack(boolean rolledBack) |
java.lang.Object getConsumerMonitor()
java.lang.String getGroupId()
org.apache.kafka.common.TopicPartition getTopicPartition()
java.util.Map<org.apache.kafka.common.TopicPartition,java.util.Set<KafkaMessageSource.KafkaAckInfo<K,V>>> getOffsets()
boolean isRolledBack()
void setRolledBack(boolean rolledBack)
boolean isAckDeferred()
void setAckDeferred(boolean ackDeferred)