クラス KafkaAutoConfiguration
java.lang.ObjectSE
org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration
@AutoConfiguration
@ConditionalOnClass(org.springframework.kafka.core.KafkaTemplate.class)
@EnableConfigurationProperties(KafkaProperties.class)
@Import({org.springframework.boot.autoconfigure.kafka.KafkaAnnotationDrivenConfiguration.class,org.springframework.boot.autoconfigure.kafka.KafkaStreamsAnnotationDrivenConfiguration.class})
public class KafkaAutoConfiguration
extends ObjectSE
Apache Kafka 用の
Auto-configuration。- 導入:
- 1.5.0
- 作成者:
- Gary Russell, Stephane Nicoll, Edd ú Mel é ndez, Nakul Mishra, Tomaz Fernandes, Moritz Halbritter, Andy Wilkinson, Phillip Webb, Andy Wilkinson, Scott Frederick
メソッドのサマリー
修飾子と型メソッド説明org.springframework.kafka.core.KafkaAdminkafkaAdmin(KafkaConnectionDetails connectionDetails, ObjectProvider<SslBundles> sslBundles) org.springframework.kafka.core.DefaultKafkaConsumerFactory<?,?> kafkaConsumerFactory(KafkaConnectionDetails connectionDetails, ObjectProvider<DefaultKafkaConsumerFactoryCustomizer> customizers, ObjectProvider<SslBundles> sslBundles) org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializerorg.springframework.kafka.core.DefaultKafkaProducerFactory<?,?> kafkaProducerFactory(KafkaConnectionDetails connectionDetails, ObjectProvider<DefaultKafkaProducerFactoryCustomizer> customizers, ObjectProvider<SslBundles> sslBundles) org.springframework.kafka.retrytopic.RetryTopicConfigurationkafkaRetryTopicConfiguration(org.springframework.kafka.core.KafkaTemplate<?, ?> kafkaTemplate) org.springframework.kafka.core.KafkaTemplate<?,?> kafkaTemplate(org.springframework.kafka.core.ProducerFactory<ObjectSE, ObjectSE> kafkaProducerFactory, org.springframework.kafka.support.ProducerListener<ObjectSE, ObjectSE> kafkaProducerListener, ObjectProvider<org.springframework.kafka.support.converter.RecordMessageConverter> messageConverter) org.springframework.kafka.transaction.KafkaTransactionManager<?,?> kafkaTransactionManager(org.springframework.kafka.core.ProducerFactory<?, ?> producerFactory)
メソッドの詳細
kafkaTemplate
@Bean @ConditionalOnMissingBean(org.springframework.kafka.core.KafkaTemplate.class) public org.springframework.kafka.core.KafkaTemplate<?,?> kafkaTemplate(org.springframework.kafka.core.ProducerFactory<ObjectSE, ObjectSE> kafkaProducerFactory, org.springframework.kafka.support.ProducerListener<ObjectSE, ObjectSE> kafkaProducerListener, ObjectProvider<org.springframework.kafka.support.converter.RecordMessageConverter> messageConverter) kafkaProducerListener
@Bean @ConditionalOnMissingBean(org.springframework.kafka.support.ProducerListener.class) public org.springframework.kafka.support.LoggingProducerListener<ObjectSE,ObjectSE> kafkaProducerListener()kafkaConsumerFactory
@Bean @ConditionalOnMissingBean(org.springframework.kafka.core.ConsumerFactory.class) public org.springframework.kafka.core.DefaultKafkaConsumerFactory<?,?> kafkaConsumerFactory(KafkaConnectionDetails connectionDetails, ObjectProvider<DefaultKafkaConsumerFactoryCustomizer> customizers, ObjectProvider<SslBundles> sslBundles) kafkaProducerFactory
@Bean @ConditionalOnMissingBean(org.springframework.kafka.core.ProducerFactory.class) public org.springframework.kafka.core.DefaultKafkaProducerFactory<?,?> kafkaProducerFactory(KafkaConnectionDetails connectionDetails, ObjectProvider<DefaultKafkaProducerFactoryCustomizer> customizers, ObjectProvider<SslBundles> sslBundles) kafkaTransactionManager
@Bean @ConditionalOnProperty(name="spring.kafka.producer.transaction-id-prefix") @ConditionalOnMissingBean public org.springframework.kafka.transaction.KafkaTransactionManager<?,?> kafkaTransactionManager(org.springframework.kafka.core.ProducerFactory<?, ?> producerFactory) kafkaJaasInitializer
@Bean @ConditionalOnProperty(name="spring.kafka.jaas.enabled") @ConditionalOnMissingBean public org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer kafkaJaasInitializer() throws IOExceptionSEkafkaAdmin
@Bean @ConditionalOnMissingBean public org.springframework.kafka.core.KafkaAdmin kafkaAdmin(KafkaConnectionDetails connectionDetails, ObjectProvider<SslBundles> sslBundles) kafkaRetryTopicConfiguration
@Bean @ConditionalOnProperty(name="spring.kafka.retry.topic.enabled") @ConditionalOnSingleCandidate(org.springframework.kafka.core.KafkaTemplate.class) public org.springframework.kafka.retrytopic.RetryTopicConfiguration kafkaRetryTopicConfiguration(org.springframework.kafka.core.KafkaTemplate<?, ?> kafkaTemplate)