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 index 7b514a9a..b0000605 100644 --- 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 class DefaultKafkaProducerFactory implements ProducerFactory, } @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); + } + } } }