@Configuration(proxyBeanMethods=false) @ConditionalOnClass(value=org.springframework.kafka.core.KafkaTemplate.class) @EnableConfigurationProperties(value=KafkaProperties.class) @Import(value={org.springframework.boot.autoconfigure.kafka.KafkaAnnotationDrivenConfiguration.class,org.springframework.boot.autoconfigure.kafka.KafkaStreamsAnnotationDrivenConfiguration.class}) public class KafkaAutoConfiguration extends ObjectSE
Auto-configuration。| コンストラクターと説明 |
|---|
KafkaAutoConfiguration(KafkaProperties properties) |
| 修飾子と型 | メソッドと説明 |
|---|---|
org.springframework.kafka.core.KafkaAdmin | kafkaAdmin() |
org.springframework.kafka.core.ConsumerFactory<?,?> | kafkaConsumerFactory(ObjectProvider<DefaultKafkaConsumerFactoryCustomizer> customizers) |
org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer | kafkaJaasInitializer() |
org.springframework.kafka.core.ProducerFactory<?,?> | kafkaProducerFactory(ObjectProvider<DefaultKafkaProducerFactoryCustomizer> customizers) |
org.springframework.kafka.support.ProducerListener<ObjectSE, ObjectSE> | kafkaProducerListener() |
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) |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSEpublic KafkaAutoConfiguration(KafkaProperties properties)
@Bean @ConditionalOnMissingBean(value=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)
@Bean @ConditionalOnMissingBean(value=org.springframework.kafka.support.ProducerListener.class) public org.springframework.kafka.support.ProducerListener<ObjectSE,ObjectSE> kafkaProducerListener()
@Bean @ConditionalOnMissingBean(value=org.springframework.kafka.core.ConsumerFactory.class) public org.springframework.kafka.core.ConsumerFactory<?,?> kafkaConsumerFactory(ObjectProvider<DefaultKafkaConsumerFactoryCustomizer> customizers)
@Bean @ConditionalOnMissingBean(value=org.springframework.kafka.core.ProducerFactory.class) public org.springframework.kafka.core.ProducerFactory<?,?> kafkaProducerFactory(ObjectProvider<DefaultKafkaProducerFactoryCustomizer> customizers)
@Bean @ConditionalOnProperty(name="spring.kafka.producer.transaction-id-prefix") @ConditionalOnMissingBean public org.springframework.kafka.transaction.KafkaTransactionManager<?,?> kafkaTransactionManager(org.springframework.kafka.core.ProducerFactory<?,?> producerFactory)
@Bean @ConditionalOnProperty(name="spring.kafka.jaas.enabled") @ConditionalOnMissingBean public org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer kafkaJaasInitializer() throws IOExceptionSE
@Bean @ConditionalOnMissingBean public org.springframework.kafka.core.KafkaAdmin kafkaAdmin()