Package es.kukenan.smartfi.kafka.config

Class KafkaProducerConfig

java.lang.Object
es.kukenan.smartfi.kafka.config.KafkaProducerConfig
@PropertySource("classpath:kafka-config.properties") @Configuration @RefreshScope public class KafkaProducerConfig extends Object
Create the configuration needed to exchange requests and responses through the mail channel.

  • Field Details

    • bootstrapAddress

      @Value("${spring.kafka.bootstrap.server}") private String bootstrapAddress
      Topic exchange to publish to.

  • Constructor Details

    • KafkaProducerConfig

      public KafkaProducerConfig()

  • Method Details

    • eventProducerFactory

      @Bean public org.springframework.kafka.core.ProducerFactory<String,Object> eventProducerFactory()
      EventConsumerFactory.
      Returns:
      consumer Factory.

    • requestKafkaTemplate

      @Bean(name="requestKafkaTemplate") public org.springframework.kafka.core.KafkaTemplate<String,Object> requestKafkaTemplate()
      EventConsumerFactory.
      Returns:
      consumer Factory.