org.springframework.boot.autoconfigure.kafka

Class KafkaAutoConfiguration

java.lang.Object

org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration

@Configuration
 @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.

Since:

1.5.0

Author:

Gary Russell, Stephane Nicoll, Eddú Meléndez, Nakul Mishra

Constructor Summary

Constructors

Constructor and Description
KafkaAutoConfiguration(KafkaProperties properties, ObjectProvider<org.springframework.kafka.support.converter.RecordMessageConverter> messageConverter)

Method Summary

Modifier and Type	Method and Description
org.springframework.kafka.core.KafkaAdmin	kafkaAdmin()
org.springframework.kafka.core.ConsumerFactory<?,?>	kafkaConsumerFactory()
org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer	kafkaJaasInitializer()
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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

KafkaAutoConfiguration

public KafkaAutoConfiguration(KafkaProperties properties,
                              ObjectProvider<org.springframework.kafka.support.converter.RecordMessageConverter> messageConverter)

Method Detail

kafkaTemplate

@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)

kafkaProducerListener

@Bean
 @ConditionalOnMissingBean(value=org.springframework.kafka.support.ProducerListener.class)
public org.springframework.kafka.support.ProducerListener<Object,Object> kafkaProducerListener()

kafkaConsumerFactory

@Bean
 @ConditionalOnMissingBean(value=org.springframework.kafka.core.ConsumerFactory.class)
public org.springframework.kafka.core.ConsumerFactory<?,?> kafkaConsumerFactory()

kafkaProducerFactory

@Bean
 @ConditionalOnMissingBean(value=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()