走航车实时websocket，小时表分表

jinpengyong

2021-09-01 7607bab6e868a51609164ce111c9d5e1046cd11f

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

@@ -36,7 +36,7 @@
    @Value("${kafka.groupId.state}")
    private String stateGroupId;

    @Bean
    @Bean("insertListenerContainerFactory")
    public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> insertListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(insertConsumerFactory());
@@ -46,7 +46,7 @@
        return factory;
    }

    @Bean
    @Bean("stateListenerContainerFactory")
    public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> stateListenerContainerFactory() {
        ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
        factory.setConsumerFactory(stateConsumerFactory());