无法暂停Spring Kafka容器

Question

我想暂停Kafka听众。

1. 我叫http://localhost:8080/pause暂停容器
2. 我发送有关主题的数据。
3. 消费者开始消费消息

我原以为消费者会被暂停，但Kafka主题的信息仍在阅读中。如何暂停消费者？我用的是2.5。0（Spring启动父级）

     @KafkaListener(id="foo" ,topics = "mytopic-3", concurrency = "3", groupId = "mytopic-1-groupid")
        

@Autowired
    private KafkaListenerEndpointRegistry kafkaListenerEndpointRegistry;
        
          @GetMapping("/pause")
            public void pause(  )
            {
                
                System.out.println(" Pausing Kafka Listener");
                kafkaListenerEndpointRegistry.getListenerContainer("foo").pause();
            }
         
        
          @Configuration
    @EnableKafka
    public class KafkaConsumerConfig implements KafkaListenerConfigurer {
        
        
        @Autowired
        private LocalValidatorFactoryBean validator;
        
       
        @Override
        public void configureKafkaListeners(KafkaListenerEndpointRegistrar registrar) {
              registrar.setValidator(this.validator);
            
        }
        

Answer 1

所有2.7. x版本都有一个错误。修正了今天容器暂停后立即恢复的问题。

引导2.5（目前为2.5.2）拉入2.7。十、下周的2.5。3释放应具有修复（SpringKafka2.7.4）。

该修复程序位于快照2.7中。您可以通过添加https://repo.spring.io/snapshot到您的构建配置。

2.7。4应在周一提供（并在本周晚些时候启动2.5.3）。

你也可以偶尔降级到2.6。9（Kafka之春）。