类 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.- 从以下版本开始:
- 1.5.0
构造器概要
构造器 构造器 说明 KafkaAutoConfiguration(KafkaProperties properties, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.support.converter.RecordMessageConverter> messageConverter)
方法概要
所有方法 实例方法 具体方法 修饰符和类型 方法 说明 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)
构造器详细资料
KafkaAutoConfiguration
public KafkaAutoConfiguration(KafkaProperties properties, org.springframework.beans.factory.ObjectProvider<org.springframework.kafka.support.converter.RecordMessageConverter> messageConverter)
方法详细资料
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
- 抛出:
IOException
kafkaAdmin
@Bean @ConditionalOnMissingBean public org.springframework.kafka.core.KafkaAdmin kafkaAdmin()