fix(log) add log for interruptedException (#3854)

2026-09-21 05:44:03 +08:00 · 2022-02-17 13:27:09 +08:00
parent a45c7bc60e
commit fc014049a2
1 changed files with 2 additions and 0 deletions
@@ -849,6 +849,8 @@ public class DefaultLitePullConsumerImpl implements MQConsumerInner {
                            break;
                    }
                    updatePullOffset(messageQueue, pullResult.getNextBeginOffset(), processQueue);
+                } catch (InterruptedException interruptedException) {
+                    log.warn("Polling thread was interrupted.", interruptedException);
                } catch (Throwable e) {
                    pullDelayTimeMills = pullTimeDelayMillsWhenException;
                    log.error("An error occurred in pull message process.", e);