クラス MockConsumerFactory<K,V>

java.lang.ObjectSE
org.springframework.kafka.mock.MockConsumerFactory<K,V>
型パラメーター:
K - 鍵の型。
V - 値の型。
実装済みのインターフェース一覧:
ConsumerFactory<K,V>
public class MockConsumerFactory<K,V> extends ObjectSE implements ConsumerFactory<K,V>
テストでの MockConsumer の使用をサポートします。
導入:
3.0.7
作成者:
Gary Russell

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

    • MockConsumerFactory

      public MockConsumerFactory(SupplierSE<org.apache.kafka.clients.consumer.MockConsumer<K,V>> consumerProvider)
      提供されたコンシューマープロバイダを使用してインスタンスを作成します。
      パラメーター:
      consumerProvider - コンシューマープロバイダー。

  • メソッドの詳細

    • getConfigurationProperties

      public MapSE<StringSE,ObjectSE> getConfigurationProperties()
      インターフェースからコピーされた説明: ConsumerFactory
      このファクトリの構成マップへの変更不可能な参照を返します。類似のファクトリを作るためのクローン作成に便利です。
      次で指定:
      インターフェース ConsumerFactory<K,V> の getConfigurationProperties 
      戻り値:
      構成。

    • createConsumer

      public org.apache.kafka.clients.consumer.Consumer<K,V> createConsumer(@Nullable StringSE groupId, @Nullable StringSE clientIdPrefix, @Nullable StringSE clientIdSuffix)
      インターフェースからコピーされた説明: ConsumerFactory
      明示的なグループ ID でコンシューマーを作成します。さらに、クライアント ID サフィックスが clientIdPrefix に追加され、存在する場合は client.id プロパティをオーバーライドします。
      次で指定:
      インターフェース ConsumerFactory<K,V> の createConsumer 
      パラメーター:
      groupId - グループ ID。
      clientIdPrefix - プレフィックス。
      clientIdSuffix - 接尾辞。
      戻り値:
      コンシューマー。

    • createConsumer

      public org.apache.kafka.clients.consumer.Consumer<K,V> createConsumer(@Nullable StringSE groupId, @Nullable StringSE clientIdPrefix, @Nullable StringSE clientIdSuffix, @Nullable PropertiesSE properties)
      インターフェースからコピーされた説明: ConsumerFactory
      明示的なグループ ID でコンシューマーを作成します。さらに、クライアント ID サフィックスが clientIdPrefix に追加され、存在する場合は client.id プロパティをオーバーライドします。さらに、ファクトリ実装がサポートしている場合は、コンシューマープロパティをオーバーライドできます。
      次で指定:
      インターフェース ConsumerFactory<K,V> の createConsumer 
      パラメーター:
      groupId - グループ ID。
      clientIdPrefix - プレフィックス。
      clientIdSuffix - 接尾辞。
      properties - オーバーライドするプロパティ。
      戻り値:
      コンシューマー。

    • isAutoCommit

      public boolean isAutoCommit()
      インターフェースからコピーされた説明: ConsumerFactory
      このファクトリによって作成されたコンシューマーが自動コミットを使用する場合は true を返します。
      次で指定:
      インターフェース ConsumerFactory<K,V> の isAutoCommit 
      戻り値:
      自動コミットの場合は true。