Class KafkaConsumerConfig

java.lang.Object
org.chenile.pubsub.kafka.configuration.KafkaConsumerConfig

@EnableKafka @Configuration public class KafkaConsumerConfig extends Object
  • Field Details

    • logger

      private static final org.slf4j.Logger logger
    • bootstrapAddress

      @Value("${spring.kafka.bootstrap-server}") private String bootstrapAddress
    • interceptorClass

      @Value("${spring.kafka.consumer.interceptor:}") private String interceptorClass
    • pubSubEntryPoint

      @Autowired private PubSubEntryPoint pubSubEntryPoint
  • Constructor Details

    • KafkaConsumerConfig

      public KafkaConsumerConfig()
  • Method Details

    • consumerFactory

      @Bean public org.springframework.kafka.core.ConsumerFactory<String,String> consumerFactory()
    • kafkaListenerContainerFactory

      @Bean public org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory<String,String> kafkaListenerContainerFactory()
    • listenGroupFoo2

      @KafkaListener(topics="chenile_global_service", groupId="foo1") public void listenGroupFoo2(@Payload String message, @Headers Map<String,Object> headers, @Header("kafka_receivedTopic") String topic, @Header("chenile_topic") String chenileTopic)
    • messageArrived

      public void messageArrived(String topic, String messageContent, Map<String,Object> headers)