@AutoConfiguration @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.DefaultKafkaConsumerFactory<?,?> | kafkaConsumerFactory(ObjectProvider<DefaultKafkaConsumerFactoryCustomizer> customizers) |
org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer | kafkaJaasInitializer() |
org.springframework.kafka.core.DefaultKafkaProducerFactory<?,?> | kafkaProducerFactory(ObjectProvider<DefaultKafkaProducerFactoryCustomizer> customizers) |
org.springframework.kafka.support.LoggingProducerListener<ObjectSE, ObjectSE> | kafkaProducerListener() |
org.springframework.kafka.retrytopic.RetryTopicConfiguration | kafkaRetryTopicConfiguration(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) |
cloneSE, equalsSE, finalizeSE, getClassSE, hashCodeSE, notifySE, notifyAllSE, toStringSE, waitSE, waitSE, waitSE
public 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.LoggingProducerListener<ObjectSE,ObjectSE> kafkaProducerListener()
@Bean @ConditionalOnMissingBean(value=org.springframework.kafka.core.ConsumerFactory.class) public org.springframework.kafka.core.DefaultKafkaConsumerFactory<?,?> kafkaConsumerFactory(ObjectProvider<DefaultKafkaConsumerFactoryCustomizer> customizers)
@Bean @ConditionalOnMissingBean(value=org.springframework.kafka.core.ProducerFactory.class) public org.springframework.kafka.core.DefaultKafkaProducerFactory<?,?> 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()
@Bean @ConditionalOnProperty(name="spring.kafka.retry.topic.enabled") @ConditionalOnSingleCandidate(value=org.springframework.kafka.core.KafkaTemplate.class) public org.springframework.kafka.retrytopic.RetryTopicConfiguration kafkaRetryTopicConfiguration(org.springframework.kafka.core.KafkaTemplate<?,?> kafkaTemplate)