| | |
| | | @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()); |
| | |
| | | return factory; |
| | | } |
| | | |
| | | @Bean |
| | | @Bean("stateListenerContainerFactory") |
| | | public KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<String, String>> stateListenerContainerFactory() { |
| | | ConcurrentKafkaListenerContainerFactory<String, String> factory = new ConcurrentKafkaListenerContainerFactory<>(); |
| | | factory.setConsumerFactory(stateConsumerFactory()); |
| | |
| | | } |
| | | |
| | | /* |
| | | * 通用配置 |
| | | * */ |
| | | * 通用配置 |
| | | * */ |
| | | public Map<String, Object> consumerConfigs() { |
| | | Map<String, Object> propsMap = new HashMap<>(); |
| | | propsMap.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, servers); |