インターフェース KafkaMessageSource.KafkaAckInfo<K,V>
- 型パラメーター:
K
- 鍵の型。V
- 値の型。
- すべてのスーパーインターフェース:
ComparableSE<KafkaMessageSource.KafkaAckInfo<K,
V>>
- すべての既知の実装クラス:
KafkaMessageSource.KafkaAckInfoImpl
- 含まれているクラス:
- KafkaMessageSource<K,
V>
public static interface KafkaMessageSource.KafkaAckInfo<K,V>
extends ComparableSE<KafkaMessageSource.KafkaAckInfo<K,V>>
KafkaAckCallback を構築するための情報。
メソッドのサマリー
修飾子と型メソッド説明MapSE<org.apache.kafka.common.TopicPartition,
SetSE<KafkaMessageSource.KafkaAckInfo<K, V>>> org.apache.kafka.common.TopicPartition
boolean
boolean
void
setAckDeferred
(boolean ackDeferred) void
setRolledBack
(boolean rolledBack) インターフェース java.lang.ComparableSE から継承されたメソッド
compareToSE
メソッドの詳細
getConsumerMonitor
ObjectSE getConsumerMonitor()getGroupId
StringSE getGroupId()getConsumer
getRecord
getTopicPartition
org.apache.kafka.common.TopicPartition getTopicPartition()getOffsets
MapSE<org.apache.kafka.common.TopicPartition,SetSE<KafkaMessageSource.KafkaAckInfo<K, getOffsets()V>>> isRolledBack
boolean isRolledBack()setRolledBack
void setRolledBack(boolean rolledBack) isAckDeferred
boolean isAckDeferred()setAckDeferred
void setAckDeferred(boolean ackDeferred)