K - 鍵の型。V - 値の型。public static class KafkaMessageSource.KafkaAckCallbackFactory<K,V> extends ObjectSE implements AcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K,V>>
| コンストラクターと説明 |
|---|
KafkaAckCallbackFactory(org.springframework.kafka.listener.ConsumerProperties consumerProperties) 提供されたプロパティを使用してインスタンスを構築します。 |
| 修飾子と型 | メソッドと説明 |
|---|---|
AcknowledgmentCallback | createCallback(KafkaMessageSource.KafkaAckInfo<K, V> info) コールバックを作成します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic KafkaAckCallbackFactory(org.springframework.kafka.listener.ConsumerProperties consumerProperties)
consumerProperties - プロパティ。public AcknowledgmentCallback createCallback(KafkaMessageSource.KafkaAckInfo<K,V> info)
AcknowledgmentCallbackFactoryAcknowledgmentCallbackFactory<KafkaMessageSource.KafkaAckInfo<K, V>> の createCallback info - 確認応答を処理するためのコールバックの情報。