@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 Object
Auto-configuration
for Apache Kafka.Constructor and Description |
---|
KafkaAutoConfiguration(KafkaProperties properties) |
Modifier and Type | Method and Description |
---|---|
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<Object,Object> |
kafkaProducerListener() |
org.springframework.kafka.core.KafkaTemplate<?,?> |
kafkaTemplate(org.springframework.kafka.core.ProducerFactory<Object,Object> kafkaProducerFactory,
org.springframework.kafka.support.ProducerListener<Object,Object> kafkaProducerListener,
ObjectProvider<org.springframework.kafka.support.converter.RecordMessageConverter> messageConverter) |
org.springframework.kafka.transaction.KafkaTransactionManager<?,?> |
kafkaTransactionManager(org.springframework.kafka.core.ProducerFactory<?,?> producerFactory) |
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<Object,Object> kafkaProducerFactory, org.springframework.kafka.support.ProducerListener<Object,Object> kafkaProducerListener, ObjectProvider<org.springframework.kafka.support.converter.RecordMessageConverter> messageConverter)
@Bean @ConditionalOnMissingBean(value=org.springframework.kafka.support.ProducerListener.class) public org.springframework.kafka.support.ProducerListener<Object,Object> 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 IOException
IOException
@Bean @ConditionalOnMissingBean public org.springframework.kafka.core.KafkaAdmin kafkaAdmin()