jinpengyong
2023-10-27 50cce907410c027875f6f8bfca9aafd8c7b44a04
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<>();