程序包 com.cdkjframework.kafka.consumer

类 ConsumerConfiguration

java.lang.Object

com.cdkjframework.kafka.consumer.ConsumerConfiguration

@Configuration
public class ConsumerConfiguration
extends Object

构造器概要

构造器

构造器	说明
ConsumerConfiguration()

方法概要

修饰符和类型	方法	说明
Map<String,Object>	consumerConfig()	消费者配置
org.springframework.kafka.core.ConsumerFactory<String,String>	consumerFactory()	消费者工厂
org.springframework.kafka.config.KafkaListenerContainerFactory<org.springframework.kafka.listener.ConcurrentMessageListenerContainer<String,String>>	kafkaListenerContainerFactory()	监听容器工厂

从类继承的方法 java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

ConsumerConfiguration

public ConsumerConfiguration()

方法详细资料

kafkaListenerContainerFactory

@Bean(name="kafkaListenerContainerFactory")
public org.springframework.kafka.config.KafkaListenerContainerFactory<org.springframework.kafka.listener.ConcurrentMessageListenerContainer<String,String>> kafkaListenerContainerFactory()

监听容器工厂

返回:

返回结果

consumerFactory

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

消费者工厂

返回:

返回消费工厂

consumerConfig

@Bean
public Map<String,Object> consumerConfig()

消费者配置

返回:

返回结果