GH-646: Avoid sync when no transaction

spring-projects · Apr 13, 2018 · 82eb21f · 82eb21f
1 parent 1b53c4b
commit 82eb21f
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java b/spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java
@@ -302,9 +302,13 @@ public void abortTransaction() throws ProducerFencedException {
 		}
 
 		@Override
-		public synchronized void close() {
-			if (this.cache != null && !this.cache.contains(this)) {
-				this.cache.offer(this);
+		public void close() {
+			if (this.cache != null) {
+				synchronized (this) {
+					if (!this.cache.contains(this)) {
+						this.cache.offer(this);
+					}
+				}
 			}
 		}