[GitHub] [pulsar] zjyingchang commented on a change in pull request #10163: Add Thread.currentThread.interrupt() after catching InterruptedException and document it in the javadoc

zjyingchang commented on a change in pull request #10163: URL: https://github.com/apache/pulsar/pull/10163#discussion_r611020045 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/util/ExceptionHandler.java ## @@ -0,0 +1,29 @@ +/** + * Licensed to the Apache So

[GitHub] [pulsar] zjyingchang commented on a change in pull request #10163: Add Thread.currentThread.interrupt() after catching InterruptedException and document it in the javadoc

zjyingchang commented on a change in pull request #10163: URL: https://github.com/apache/pulsar/pull/10163#discussion_r610986444 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java ## @@ -453,6 +455,7 @@ public UnAckedMessageTracker getUnA

[GitHub] [pulsar] zjyingchang commented on a change in pull request #10163: Add Thread.currentThread.interrupt() after catching InterruptedException and document it in the javadoc

zjyingchang commented on a change in pull request #10163: URL: https://github.com/apache/pulsar/pull/10163#discussion_r610310852 ## File path: pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConsumerImpl.java ## @@ -398,6 +398,7 @@ public UnAckedMessageTracker getUnA