From d57091d791185eff6d2665434b3d03932d3ee338 Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Thu, 16 Sep 2021 14:41:08 -0400 Subject: [PATCH] GH-1145: Remove destroying producer factory Remove the un-ncessary call to destroy the producer when checking for partitions. This way, the producer is cached and reused at the first time data is produced. Resolves https://github.com/spring-cloud/spring-cloud-stream-binder-kafka/issues/1145 --- .../cloud/stream/binder/kafka/KafkaMessageChannelBinder.java | 3 --- 1 file changed, 3 deletions(-) diff --git a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java index 4da85be76..be2526dc3 100644 --- a/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java +++ b/spring-cloud-stream-binder-kafka/src/main/java/org/springframework/cloud/stream/binder/kafka/KafkaMessageChannelBinder.java @@ -399,9 +399,6 @@ public class KafkaMessageChannelBinder extends List partitionsFor = producer .partitionsFor(destination.getName()); producer.close(); - if (transMan == null) { - ((DisposableBean) producerFB).destroy(); - } return partitionsFor; }, destination.getName()); this.topicsInUse.put(destination.getName(),