クラス MockConsumerFactory<K,V>
java.lang.ObjectSE
org.springframework.kafka.mock.MockConsumerFactory<K,V>
- 型パラメーター:
K- 鍵の型。V- 値の型。
- 実装済みのインターフェース一覧:
ConsumerFactory<K,V>
テストでの
MockConsumer の使用をサポートします。- 導入:
- 3.0.7
- 作成者:
- Gary Russell
ネストされたクラスの概要
インターフェース ConsumerFactory から継承されたネストクラス / インターフェース
ConsumerFactory.Listener<K,V> コンストラクター概要
コンストラクターコンストラクター説明MockConsumerFactory(SupplierSE<org.apache.kafka.clients.consumer.MockConsumer<K, V>> consumerProvider) 提供されたコンシューマープロバイダを使用してインスタンスを作成します。方法の概要
修飾子と型メソッド説明createConsumer(@Nullable StringSE groupId, @Nullable StringSE clientIdPrefix, @Nullable StringSE clientIdSuffix) 明示的なグループ ID でコンシューマーを作成します。さらに、クライアント ID サフィックスが clientIdPrefix に追加され、存在する場合はclient.idプロパティをオーバーライドします。createConsumer(@Nullable StringSE groupId, @Nullable StringSE clientIdPrefix, @Nullable StringSE clientIdSuffix, @Nullable PropertiesSE properties) 明示的なグループ ID でコンシューマーを作成します。さらに、クライアント ID サフィックスが clientIdPrefix に追加され、存在する場合はclient.idプロパティをオーバーライドします。このファクトリの構成マップへの変更不可能な参照を返します。booleanこのファクトリによって作成されたコンシューマーが自動コミットを使用する場合は true を返します。
コンストラクターの詳細
MockConsumerFactory
public MockConsumerFactory(SupplierSE<org.apache.kafka.clients.consumer.MockConsumer<K, V>> consumerProvider) 提供されたコンシューマープロバイダを使用してインスタンスを作成します。- パラメーター:
consumerProvider- コンシューマープロバイダー。
方法の詳細
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。