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)