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

インターフェース ThreadStateProcessor

すべての既知のサブインターフェース:
BatchInterceptor<K,V>, RecordInterceptor<K,V>
すべての既知の実装クラス:
CompositeBatchInterceptor, CompositeRecordInterceptor
public interface ThreadStateProcessor
Consumer が使用可能な場合に、スレッドにバインドされたリソースを管理するための一般的なインターフェース。
導入:
2.8
作成者:
Karol Dowbecki, Gary Russell

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    default void
    clearThreadState(org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
    setupThreadState(Consumer) で設定されたスレッドにバインドされたリソースをクリアするために呼び出します。
    default void
    setupThreadState(org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
    Consumer を含む囲まれた操作の全期間にわたって利用可能になるスレッドバウンドリソースをセットアップするために呼び出します。

  • メソッドの詳細

    • setupThreadState

      default void setupThreadState(org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
      Consumer を含む囲まれた操作の全期間にわたって利用可能になるスレッドバウンドリソースをセットアップするために呼び出します。
      パラメーター:
      consumer - コンシューマー。

    • clearThreadState

      default void clearThreadState(org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
      setupThreadState(Consumer) で設定されたスレッドにバインドされたリソースをクリアするために呼び出します。
      パラメーター:
      consumer - コンシューマー。