diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java index e89f390670335..5e0579fc73aa2 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ProducerImpl.java @@ -1799,7 +1799,6 @@ private void batchMessageAndSend() { processOpSendMsg(opSendMsg); } } catch (PulsarClientException e) { - Thread.currentThread().interrupt(); semaphoreRelease(batchMessageContainer.getNumMessagesInBatch()); } catch (Throwable t) { semaphoreRelease(batchMessageContainer.getNumMessagesInBatch());