这是来自kafkamessagelistenercontainer的代码，在什么上下文中，它们有可能发生中断异常，可以被这个代码抛出，突然出现在我的应用程序日志中，它正在使用来自主题和进程的消息，然后确认消息，见下面的错误消息

Interrupted while queuing ack for

@Override
            public void acknowledge() {
                try {
                    if (ListenerConsumer.this.autoCommit) {
                        throw new IllegalStateException("Manual acks are not allowed when auto commit is used");
                    }
                    ListenerConsumer.this.acks.put(this.record);
                }
                catch (InterruptedException e) {
                    Thread.currentThread().interrupt();
                  **throw new KafkaException("Interrupted while queuing ack for " + this.record, e);**
                }
                if (this.immediate) {
                    ListenerConsumer.this.consumer.wakeup();
                }
            }