无法暂停 Spring Kafka 容器

大佬教程收集整理的这篇文章主要介绍了无法暂停 Spring Kafka 容器，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决无法暂停 Spring Kafka 容器？

开发过程中遇到无法暂停 Spring Kafka 容器的问题如何解决？下面主要结合日常开发的经验，给出你关于无法暂停 Spring Kafka 容器的解决方法建议，希望对你解决无法暂停 Spring Kafka 容器有所启发或帮助；

我想暂停 Kafka 监听器。@H_696_3@

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

我预计消费者会被暂停，但仍在从 Kafka 主题读取消息。 我怎样才能暂停消费者？ 我正在使用 2.5.0 (Spring Boot Parent)@H_696_3@

     @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);
            
        }
        

解决方法

大佬总结

以上是大佬教程为你收集整理的无法暂停 Spring Kafka 容器全部内容，希望文章能够帮你解决无法暂停 Spring Kafka 容器所遇到的程序开发问题。

如果觉得大佬教程网站内容还不错，欢迎将大佬教程推荐给程序员好友。

本图文内容来源于网友网络收集整理提供，作为学习参考使用，版权属于原作者。
如您有任何意见或建议可联系处理。小编QQ：384754419，请注明来意。