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