Package callofproject.dev.community.config.kafka

Class ProjectInfoConsumerConfig

java.lang.Object
callofproject.dev.community.config.kafka.ProjectInfoConsumerConfig
@EnableKafka @Configuration public class ProjectInfoConsumerConfig extends Object
Author:
Nuri Can ÖZTÜRK This class is a Spring Configuration class that provides configuration for Kafka consumer.

  • Constructor Details

    • ProjectInfoConsumerConfig

      public ProjectInfoConsumerConfig()

  • Method Details

    • configProjectInfoKafkaListener

      @Bean public org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<String,ProjectInfoKafkaDTO> configProjectInfoKafkaListener()
      Config for ProjectInfoKafkaDTO

    • projectConsumerConfig

      @Bean public org.springframework.kafka.core.ConsumerFactory<String,ProjectInfoKafkaDTO> projectConsumerConfig()
      Consumer config for ProjectInfoKafkaDTO