public class ConcurrentKafkaListenerContainerFactoryConfigurer extends ObjectSE
ConcurrentKafkaListenerContainerFactory
を適切なデフォルトで設定します。コンストラクターと説明 |
---|
ConcurrentKafkaListenerContainerFactoryConfigurer() |
修飾子と型 | メソッドと説明 |
---|---|
void | configure(org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<ObjectSE, ObjectSE> listenerFactory, org.springframework.kafka.core.ConsumerFactory<ObjectSE, ObjectSE> consumerFactory) 指定された Kafka リスナーコンテナーファクトリを構成します。 |
void | setCommonErrorHandler(org.springframework.kafka.listener.CommonErrorHandler commonErrorHandler) 使用する CommonErrorHandler を設定します。 |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public ConcurrentKafkaListenerContainerFactoryConfigurer()
public void setCommonErrorHandler(org.springframework.kafka.listener.CommonErrorHandler commonErrorHandler)
CommonErrorHandler
を設定します。commonErrorHandler
- エラーハンドラー。public void configure(org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<ObjectSE,ObjectSE> listenerFactory, org.springframework.kafka.core.ConsumerFactory<ObjectSE,ObjectSE> consumerFactory)
listenerFactory
- 構成する ConcurrentKafkaListenerContainerFactory
インスタンス consumerFactory
- 使用する ConsumerFactory