moral.git - Gitblit

summary
reflog
commits
tree
tickets
docs
forks
compare

cjl

2023-08-11 e6aa3704532bf130d577620758881f11c53c36fb

 screen-api/src/main/java/com/moral/api/config/kafka/KafkaConsumerConfig.java

@@ -46,7 +46,7 @@
    public ConsumerFactory<String, String> consumerFactory() {
        return new DefaultKafkaConsumerFactory<>(consumerConfigs());
    }
    

    @Bean("secondDataListenerFactory")
    public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> secondDataListenerFactory(){
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();

			@@ -46,7 +46,7 @@
			public ConsumerFactory<String, String> consumerFactory() {
			return new DefaultKafkaConsumerFactory<>(consumerConfigs());
			}


			@Bean("secondDataListenerFactory")
			public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> secondDataListenerFactory(){
			ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();