クラス 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 voidinitializeContainer(ConcurrentMessageListenerContainer<K, V> instance, KafkaListenerEndpoint endpoint) さらに、指定されたコンテナーを初期化します。voidsetConcurrency(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- エンドポイント。