クラス ConcurrentKafkaListenerContainerFactory<K,V>
java.lang.ObjectSE
org.springframework.kafka.config.AbstractKafkaListenerContainerFactory < ConcurrentMessageListenerContainer <K、V>、K、V>
org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<K,V>
- 型パラメーター:
K
- 鍵の型。V
- 値の型。
- 実装されたすべてのインターフェース:
Aware
、ApplicationContextAware
、ApplicationEventPublisherAware
、KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,
V>>
public class ConcurrentKafkaListenerContainerFactory<K,V>
extends AbstractKafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,V>,K,V>
ConcurrentMessageListenerContainer
を構築するための KafkaListenerContainerFactory
実装。 これは、ほとんどのユーザーにとってデフォルトであり、そのようなコンテナー定義を手動で構築するのに使用されるユーザーにとって適切な移行パスである必要があります。このファクトリは、主に KafkaListener
アノテーション付きメソッドのコンテナーを作成するためのものですが、任意のコンテナーの作成にも使用できます。KafkaListener
アノテーション付きメソッドのコンテナーのみが KafkaListenerEndpointRegistry
に追加されます。
- 作成者:
- Stephane Nicoll, Gary Russell, Artem Bilan, Murali Reddy
フィールドサマリー
クラス org.springframework.kafka.config.AbstractKafkaListenerContainerFactory から継承されたフィールド
logger
コンストラクターのサマリー
コンストラクターメソッドのサマリー
修飾子と型メソッド説明protected ConcurrentMessageListenerContainer<K,
V> createContainerInstance
(KafkaListenerEndpoint endpoint) 空のコンテナーインスタンスを作成します。protected void
initializeContainer
(ConcurrentMessageListenerContainer<K, V> instance, KafkaListenerEndpoint endpoint) さらに、指定されたコンテナーを初期化します。void
setConcurrency
(IntegerSE concurrency) コンテナーの同時実行性を指定します。クラス org.springframework.kafka.config.AbstractKafkaListenerContainerFactory から継承されたメソッド
createContainer, createContainer, createContainer, createContainer, createListenerContainer, customizeContainer, getConsumerFactory, getContainerProperties, isBatchListener, setAckDiscarded, setAfterRollbackProcessor, setApplicationContext, setApplicationEventPublisher, setAutoStartup, setBatchInterceptor, setBatchListener, setBatchMessageConverter, setBatchToRecordAdapter, setChangeConsumerThreadName, setCommonErrorHandler, setConsumerFactory, setContainerCustomizer, setCorrelationHeaderName, setMissingTopicsFatal, setPhase, setRecordFilterStrategy, setRecordInterceptor, setRecordMessageConverter, setReplyHeadersConfigurer, setReplyTemplate, setThreadNameSupplier
コンストラクターの詳細
ConcurrentKafkaListenerContainerFactory
public ConcurrentKafkaListenerContainerFactory()
メソッドの詳細
setConcurrency
コンテナーの同時実行性を指定します。- パラメーター:
concurrency
- 作成するコンシューマーの数。- 関連事項:
createContainerInstance
protected ConcurrentMessageListenerContainer<K,V> createContainerInstance(KafkaListenerEndpoint endpoint) クラスからコピーされた説明:AbstractKafkaListenerContainerFactory
空のコンテナーインスタンスを作成します。- 次で指定:
- クラス
AbstractKafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,
のV>, K, V> createContainerInstance
- パラメーター:
endpoint
- エンドポイント。- 戻り値:
- 新しいコンテナーインスタンス。
initializeContainer
protected void initializeContainer(ConcurrentMessageListenerContainer<K, V> instance, KafkaListenerEndpoint endpoint) クラスからコピーされた説明:AbstractKafkaListenerContainerFactory
さらに、指定されたコンテナーを初期化します。サブクラスはこのメソッドを継承して、必要に応じて追加の構成を適用できます。
- オーバーライド:
- クラス
AbstractKafkaListenerContainerFactory<ConcurrentMessageListenerContainer<K,
のV>, K, V> initializeContainer
- パラメーター:
instance
- 構成するコンテナーインスタンス。endpoint
- エンドポイント。