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

クラス DefaultTransactionIdSuffixStrategy

java.lang.ObjectSE
org.springframework.kafka.core.DefaultTransactionIdSuffixStrategy
実装されたすべてのインターフェース:
TransactionIdSuffixStrategy
public class DefaultTransactionIdSuffixStrategy extends ObjectSE implements TransactionIdSuffixStrategy
トランザクションプロデューサーサフィックスを管理するための TransactionIdSuffixStrategy 実装。maxCache が 0 より大きい場合、サフィックスはキャッシュされ、再利用されます。それ以外の場合、サフィックスはオンザフライで生成されます。

キャッシュは `transactional.id` プレフィックスごとに行われます。キャッシュサイズは maxCache によって制限されます。値が 0 の場合、キャッシュと制限は行われず、`transactional.id` がオンザフライで生成されます。

導入:
3.2
作成者:
Ilya Starchenko

  • コンストラクターの概要

    コンストラクター
    コンストラクター
    説明
    DefaultTransactionIdSuffixStrategy(int maxCache)
    指定されたキャッシュのサイズを使用してトランザクション ID サフィックス戦略を構築します。

  • メソッドのサマリー

    修飾子と型
    メソッド
    説明
    StringSE
    acquireSuffix(StringSE txIdPrefix)
    トランザクションプロデューサーのサフィックスをキャッシュから取得するか、キャッシュが無効になっている場合は新しいサフィックスを生成します。
    void
    releaseSuffix(StringSE txIdPrefix, StringSE suffix)
    トランザクションプロデューサーのサフィックスを解放します。

    クラス java.lang.ObjectSE から継承されたメソッド

    clone, equalsSE, finalize, getClass, hashCode, notify, notifyAll, toString, wait, waitSE, waitSE

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

    • DefaultTransactionIdSuffixStrategy

      public DefaultTransactionIdSuffixStrategy(int maxCache)
      指定されたキャッシュのサイズを使用してトランザクション ID サフィックス戦略を構築します。
      パラメーター:
      maxCache - キャッシュの最大サイズ。

  • メソッドの詳細

    • acquireSuffix

      public StringSE acquireSuffix(StringSE txIdPrefix)
      トランザクションプロデューサーのサフィックスをキャッシュから取得するか、キャッシュが無効になっている場合は新しいサフィックスを生成します。
      次で指定:
      インターフェース TransactionIdSuffixStrategy の acquireSuffix 
      パラメーター:
      txIdPrefix - トランザクション ID プレフィックス。
      戻り値:
      接尾辞。
      例外:
      NoProducerAvailableException - キャッシュが有効になっていて、サフィックスが利用できない場合。

    • releaseSuffix

      public void releaseSuffix(StringSE txIdPrefix, StringSE suffix)
      インターフェースからコピーされた説明: TransactionIdSuffixStrategy
      トランザクションプロデューサーのサフィックスを解放します。
      次で指定:
      インターフェース TransactionIdSuffixStrategy の releaseSuffix 
      パラメーター:
      txIdPrefix - トランザクション ID プレフィックス。
      suffix - 接尾辞。