クラス ProducerFactoryUtils

java.lang.ObjectSE
org.springframework.kafka.core.ProducerFactoryUtils
public final class ProducerFactoryUtils extends ObjectSE
Spring ベースの Kafka DefaultKafkaProducerFactory を管理するためのヘルパークラス、特に特定の ProducerFactory のトランザクション Kafka リソースを取得するためのクラス。

主にフレームワーク内での内部使用向け。

作成者:
Gary Russell

  • フィールドの詳細

    • DEFAULT_CLOSE_TIMEOUT

      public static final DurationSE DEFAULT_CLOSE_TIMEOUT
      デフォルトのクローズタイムアウト (5 秒)。

  • 方法の詳細

    • getTransactionalResourceHolder

      public static <K,V> KafkaResourceHolder<K,V> getTransactionalResourceHolder(ProducerFactory<K,V> producerFactory)
      現在のトランザクションと同期している Producer を取得します (存在する場合)。
      型パラメーター:
      K - 鍵の型。
      V - 値の型。
      パラメーター:
      producerFactory - チャネルを取得するための ProducerFactory
      戻り値:
      リソースホルダー。

    • getTransactionalResourceHolder

      public static <K,V> KafkaResourceHolder<K,V> getTransactionalResourceHolder(ProducerFactory<K,V> producerFactory, DurationSE closeTimeout)
      現在のトランザクションと同期している Producer を取得します (存在する場合)。
      型パラメーター:
      K - 鍵の型。
      V - 値の型。
      パラメーター:
      producerFactory - チャネルを取得するための ProducerFactory
      closeTimeout - プロデューサーのクローズタイムアウト。
      戻り値:
      リソースホルダー。
      導入:
      2.1.14

    • getTransactionalResourceHolder

      public static <K,V> KafkaResourceHolder<K,V> getTransactionalResourceHolder(ProducerFactory<K,V> producerFactory, @Nullable StringSE txIdPrefix, DurationSE closeTimeout)
      現在のトランザクションと同期している Producer を取得します (存在する場合)。
      型パラメーター:
      K - 鍵の型。
      V - 値の型。
      パラメーター:
      producerFactory - チャネルを取得するための ProducerFactory
      txIdPrefix - トランザクション ID プレフィックス。null の場合、プロデューサーファクトリプレフィックスが使用されます。
      closeTimeout - プロデューサーのクローズタイムアウト。
      戻り値:
      リソースホルダー。
      導入:
      2.3

    • releaseResources

      public static <K,V> void releaseResources(@Nullable KafkaResourceHolder<K,V> resourceHolder)