Class KafkaAutoConfiguration
- java.lang.Object
- org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration
@Configuration @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 Object
Auto-configurationfor Apache Kafka.- Since:
- 1.5.0
Constructor Summary
Constructors Constructor Description KafkaAutoConfiguration(KafkaProperties properties, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.support.converter.RecordMessageConverter> messageConverter)
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.springframework.kafka.core.KafkaAdminkafkaAdmin()org.springframework.kafka.core.ConsumerFactory<?,?>kafkaConsumerFactory()org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializerkafkaJaasInitializer()org.springframework.kafka.core.ProducerFactory<?,?>kafkaProducerFactory()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)org.springframework.kafka.transaction.KafkaTransactionManager<?,?>kafkaTransactionManager(org.springframework.kafka.core.ProducerFactory<?,?> producerFactory)
Constructor Detail
KafkaAutoConfiguration
public KafkaAutoConfiguration(KafkaProperties properties, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.support.converter.RecordMessageConverter> messageConverter)
Method Detail
kafkaTemplate
@Bean @ConditionalOnMissingBean(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)
kafkaProducerListener
@Bean @ConditionalOnMissingBean(org.springframework.kafka.support.ProducerListener.class) public org.springframework.kafka.support.ProducerListener<Object,Object> kafkaProducerListener()
kafkaConsumerFactory
@Bean @ConditionalOnMissingBean(org.springframework.kafka.core.ConsumerFactory.class) public org.springframework.kafka.core.ConsumerFactory<?,?> kafkaConsumerFactory()
kafkaProducerFactory
@Bean @ConditionalOnMissingBean(org.springframework.kafka.core.ProducerFactory.class) public org.springframework.kafka.core.ProducerFactory<?,?> kafkaProducerFactory()
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 IOException
- Throws:
IOException
kafkaAdmin
@Bean @ConditionalOnMissingBean public org.springframework.kafka.core.KafkaAdmin kafkaAdmin()