パッケージ org.springframework.kafka.listener

クラス AbstractConsumerSeekAware

java.lang.ObjectSE
org.springframework.kafka.listener.AbstractConsumerSeekAware
実装されたすべてのインターフェース:
ConsumerSeekAware
public abstract class AbstractConsumerSeekAware extends ObjectSE implements ConsumerSeekAware
リスナーの ConsumerSeekAware.ConsumerSeekCallback を管理します。リスナーがこのクラスをサブクラス化すると、コールバック自体を追跡しなくても、任意のトピック / パーティションを簡単に探すことができます。
導入:
2.3
作成者:
Gary Russell

  • コンストラクターの詳細

    • AbstractConsumerSeekAware

      public AbstractConsumerSeekAware()

  • メソッドの詳細

    • registerSeekCallback

      public void registerSeekCallback(ConsumerSeekAware.ConsumerSeekCallback callback)
      インターフェースからコピーされた説明: ConsumerSeekAware
      任意のタイミングでシークする際に使用するコールバックを登録します。ConcurrentMessageListenerContainer または複数のコンテナー内の同じリスナーインスタンスで使用する場合、リスナーはコールバックを ThreadLocal またはスレッドによってキー設定されたマップに保存する必要があります。
      次で指定:
      インターフェース ConsumerSeekAware の registerSeekCallback 
      パラメーター:
      callback - コールバック。

    • onPartitionsAssigned

      public void onPartitionsAssigned(MapSE<org.apache.kafka.common.TopicPartition,LongSE> assignments, ConsumerSeekAware.ConsumerSeekCallback callback)
      インターフェースからコピーされた説明: ConsumerSeekAware
      グループ管理を使用する場合。パーティションの割り当てが変更されたときに呼び出されます。
      次で指定:
      インターフェース ConsumerSeekAware の onPartitionsAssigned 
      パラメーター:
      assignments - 新しい割り当てとその現在のオフセット。
      callback - 割り当て後に最初のシークを実行するためのコールバック。

    • onPartitionsRevoked

      public void onPartitionsRevoked(CollectionSE<org.apache.kafka.common.TopicPartition> partitions)
      インターフェースからコピーされた説明: ConsumerSeekAware
      グループ管理を使用する場合。パーティションの割り当てが取り消されたときに呼び出されます。リスナーは、このスレッドで ConsumerSeekAware.registerSeekCallback(ConsumerSeekCallback) から保存されたコールバックを破棄する必要があります。
      次で指定:
      インターフェース ConsumerSeekAware の onPartitionsRevoked 
      パラメーター:
      partitions - 取り消されたパーティション。

    • unregisterSeekCallback

      public void unregisterSeekCallback()
      インターフェースからコピーされた説明: ConsumerSeekAware
      リスナーコンシューマーが終了したときに呼び出され、実装がスレッドローカルなどの状態をクリーンアップできるようにします。
      次で指定:
      インターフェース ConsumerSeekAware の unregisterSeekCallback 

    • getSeekCallbackFor

      @Nullable protected ConsumerSeekAware.ConsumerSeekCallback getSeekCallbackFor(org.apache.kafka.common.TopicPartition topicPartition)
      指定されたトピック / パーティションのコールバックを返します。
      パラメーター:
      topicPartition - トピック / パーティション。
      戻り値:
      コールバック（または割り当てがない場合は null）。

    • getSeekCallbacks

      protected MapSE<org.apache.kafka.common.TopicPartition,ConsumerSeekAware.ConsumerSeekCallback> getSeekCallbacks()
      現在割り当てられているすべてのパーティションのコールバックのマップ。
      戻り値:
      地図。

    • getCallbacksAndTopics

      protected MapSE<ConsumerSeekAware.ConsumerSeekCallback,ListSE<org.apache.kafka.common.TopicPartition>> getCallbacksAndTopics()
      現在登録されているコールバックとそれに関連する TopicPartition を返します。
      戻り値:
      コールバックとパーティションのマップ。
      導入:
      2.6

    • seekToBeginning

      public void seekToBeginning()
      最初に割り当てられたすべてのパーティションを探します。
      導入:
      2.6

    • seekToEnd

      public void seekToEnd()
      割り当てられたすべてのパーティションを最後まで探します。
      導入:
      2.6

    • seekToTimestamp

      public void seekToTimestamp(long time)
      タイムスタンプで表されるオフセットに割り当てられたすべてのパーティションを探します。
      パラメーター:
      time - 求める時間。
      導入:
      2.6