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