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

クラス MockProducerFactory<K,V>

java.lang.ObjectSE
org.springframework.kafka.mock.MockProducerFactory<K,V>
型パラメーター:
K - 鍵の型。
V - 値の型。
実装されたすべてのインターフェース:
ProducerFactory<K,V>
public class MockProducerFactory<K,V> extends ObjectSE implements ProducerFactory<K,V>
テストでの MockProducer の使用をサポートします。
導入:
3.0.7
作成者:
Gary Russell

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

    • MockProducerFactory

      public MockProducerFactory(SupplierSE<org.apache.kafka.clients.producer.MockProducer<K,V>> producerProvider)
      トランザクションプロデューサーをサポートしないインスタンスを作成します。
      パラメーター:
      producerProvider - MockProducer の場合は SupplierSE。

    • MockProducerFactory

      public MockProducerFactory(BiFunctionSE<BooleanSE,StringSE,org.apache.kafka.clients.producer.MockProducer<K,V>> producerProvider, @Nullable StringSE defaultTxId)
      提供されたプロデューサープロバイダー BiFunctionSE を使用して、トランザクションをサポートするインスタンスを作成します。この関数には 2 つのパラメーターがあります。1 つはトランザクションプロデューサーがリクエストされているかどうかを示すブール値で、true の場合はそのプロデューサーのトランザクション ID プレフィックスです。
      パラメーター:
      producerProvider - プロバイダー機能。
      defaultTxId - デフォルトのトランザクション ID。

  • メソッドの詳細

    • transactionCapable

      public boolean transactionCapable()
      インターフェースからコピーされた説明: ProducerFactory
      ファクトリがトランザクションをサポートしている場合は true を返します。
      次で指定:
      インターフェース ProducerFactory<K,V> の transactionCapable 
      戻り値:
      トランザクションの場合は true。

    • createProducer

      public org.apache.kafka.clients.producer.Producer<K,V> createProducer()
      インターフェースからコピーされた説明: ProducerFactory
      ファクトリがそのように構成されている場合にトランザクションになるプロデューサーを作成します。
      次で指定:
      インターフェース ProducerFactory<K,V> の createProducer 
      戻り値:
      プロデューサー。
      関連事項:

    • createProducer

      public org.apache.kafka.clients.producer.Producer<K,V> createProducer(@Nullable StringSE txIdPrefix)
      インターフェースからコピーされた説明: ProducerFactory
      オーバーライドされたトランザクション ID プレフィックスを使用してプロデューサーを作成します。
      次で指定:
      インターフェース ProducerFactory<K,V> の createProducer 
      パラメーター:
      txIdPrefix - トランザクション ID プレフィックス。
      戻り値:
      プロデューサー。

    • createNonTransactionalProducer

      public org.apache.kafka.clients.producer.Producer<K,V> createNonTransactionalProducer()
      インターフェースからコピーされた説明: ProducerFactory
      非トランザクションプロデューサーを作成します。
      次で指定:
      インターフェース ProducerFactory<K,V> の createNonTransactionalProducer 
      戻り値:
      プロデューサー。
      関連事項: