Package es.kukenan.smartfi.kafka.config

Class KafkaConsumerConfig

java.lang.Object
es.kukenan.smartfi.kafka.config.KafkaConsumerConfig
@EnableKafka @Configuration public class KafkaConsumerConfig 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

    • KafkaConsumerConfig

      public KafkaConsumerConfig()

  • Method Details

    • multiTypeConverter

      @Bean public org.springframework.kafka.support.converter.RecordMessageConverter multiTypeConverter()
      EventConsumerFactory.
      Returns:
      consumer Factory.

    • multiTypeConsumerFactory

      public org.springframework.kafka.core.ConsumerFactory<String,Object> multiTypeConsumerFactory()
      EventConsumerFactory.
      Returns:
      consumer Factory.

    • eventKafkaListenerContainerFactory

      @Bean public org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<String,Object> eventKafkaListenerContainerFactory()
      EventConsumerFactory.
      Returns:
      consumer Factory.