@EnableKafka
@Configuration
public class KafkaConsumerConfig
extends java.lang.Object
Constructor and Description |
---|
KafkaConsumerConfig(java.lang.String bootstrapServer) |
Modifier and Type | Method and Description |
---|---|
org.springframework.kafka.core.ConsumerFactory<java.lang.String,java.lang.String> |
consumerFactory() |
org.springframework.kafka.config.KafkaListenerContainerFactory<org.springframework.kafka.listener.ConcurrentMessageListenerContainer<java.lang.String,java.lang.String>> |
kafkaListenerContainerFactory(org.springframework.kafka.core.ConsumerFactory<java.lang.String,java.lang.String> consumerFactory) |
public KafkaConsumerConfig(@Value(value="${kafka.bootstrap-servers}") java.lang.String bootstrapServer)
@Bean public org.springframework.kafka.core.ConsumerFactory<java.lang.String,java.lang.String> consumerFactory()
@Bean public org.springframework.kafka.config.KafkaListenerContainerFactory<org.springframework.kafka.listener.ConcurrentMessageListenerContainer<java.lang.String,java.lang.String>> kafkaListenerContainerFactory(org.springframework.kafka.core.ConsumerFactory<java.lang.String,java.lang.String> consumerFactory)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.