Package org.springframework.boot.autoconfigure.kafka

Class KafkaAutoConfiguration

java.lang.Object

org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration

@AutoConfiguration
@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})
@ImportRuntimeHints(org.springframework.boot.autoconfigure.kafka.KafkaAutoConfiguration.KafkaRuntimeHints.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, Tomaz Fernandes, Moritz Halbritter, Andy Wilkinson, Phillip Webb, Andy Wilkinson, Scott Frederick

Method Summary

Modifier and Type	Method	Description
org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer	kafkaJaasInitializer()
org.springframework.kafka.support.LoggingProducerListener<Object,Object>	kafkaProducerListener()
org.springframework.kafka.retrytopic.RetryTopicConfiguration	kafkaRetryTopicConfiguration(org.springframework.kafka.core.KafkaTemplate<?,?> kafkaTemplate)
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)

Methods inherited from class java.lang.Object

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

Method Details

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,
 ObjectProvider<org.springframework.kafka.support.converter.RecordMessageConverter> messageConverter)

kafkaProducerListener

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

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
@ConditionalOnBooleanProperty("spring.kafka.jaas.enabled")
@ConditionalOnMissingBean
public org.springframework.kafka.security.jaas.KafkaJaasLoginModuleInitializer kafkaJaasInitializer()
                                                                                             throws IOException

Throws:

IOException

kafkaRetryTopicConfiguration

@Bean
@ConditionalOnBooleanProperty("spring.kafka.retry.topic.enabled")
@ConditionalOnSingleCandidate(org.springframework.kafka.core.KafkaTemplate.class)
public org.springframework.kafka.retrytopic.RetryTopicConfiguration kafkaRetryTopicConfiguration(org.springframework.kafka.core.KafkaTemplate<?,?> kafkaTemplate)