LoggingCommitCallback (Spring for Apache Kafka API) - Javadoc

java.lang.ObjectSE

org.springframework.kafka.listener.LoggingCommitCallback

実装されたすべてのインターフェース:: org.apache.kafka.clients.consumer.OffsetCommitCallback

public final class LoggingCommitCallback extends ObjectSE implements org.apache.kafka.clients.consumer.OffsetCommitCallback

成功した場合は DEBUG レベルで、失敗した場合は ERROR のコミット結果をログに記録します。

導入:: 2.2.4
作成者:: Gary Russell

コンストラクターのサマリー
コンストラクター
コンストラクター
説明
LoggingCommitCallback()
メソッドのサマリー
修飾子と型
メソッド
説明
void
onComplete(MapSE<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, ExceptionSE exception)
クラス java.lang.ObjectSE から継承されたメソッド
clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

コンストラクターの詳細
- LoggingCommitCallback
  public LoggingCommitCallback()
メソッドの詳細
- onComplete
  public void onComplete(MapSE<org.apache.kafka.common.TopicPartition,org.apache.kafka.clients.consumer.OffsetAndMetadata> offsets, ExceptionSE exception)
  次で指定:
  インターフェース org.apache.kafka.clients.consumer.OffsetCommitCallback の onComplete