We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent ced67f1 commit 2bbcc8fCopy full SHA for 2bbcc8f
spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java
@@ -735,9 +735,7 @@ public void close(@Nullable Duration timeout) {
735
if (!this.cache.contains(this)
736
&& !this.cache.offer(this)) {
737
this.closed = true;
738
- this.delegate.close(this.producerFailed instanceof TimeoutException
739
- ? CLOSE_TIMEOUT_AFTER_TX_TIMEOUT
740
- : timeout);
+ this.delegate.close(timeout);
741
}
742
743
0 commit comments