title: I want to use pause() and resume() methond with @KafkaListener ,but it not failed
body: <p>the code :</p>
  <pre class="lang-java prettyprint-override"><code>@KafkaListener(id = &quot;${spring.kafka.consumer.listener-id}&quot;, idIsGroup = false, groupId = &quot;${spring.kafka.consumer.group-id}&quot;, topics = &quot;#{'${srm.xdp.topics}'.split(',')}&quot;, containerFactory = &quot;consumerFactory&quot;, errorHandler = &quot;consumerAwareErrorHandler&quot;)
      public void onDealMessage(List&lt;ConsumerRecord&lt;String, String&gt;&gt; records, Acknowledgment ack) {
          MessageListenerContainer messageListenerContainer = kafkaListenerEndpointRegistry.getListenerContainer(listenerId);
          messageListenerContainer.pause();
          if (messageListenerContainer.isContainerPaused()) {
              System.out.println(&quot;container paused!!!&quot;);
          }
          for (ConsumerRecord&lt;String, String&gt; record : records) {
              System.out.println(record);
              // business login dealwith
          }
  
          if (!messageListenerContainer.isContainerPaused()) {
              System.out.println(&quot;container not paused!!!&quot;);
          }
          ack.acknowledge();
          messageListenerContainer.resume();
      }
  </code></pre>