Fix local variable name

https://build.spring.io/browse/SK-SK13X-129/
spring-projects · Oct 28, 2019 · 7f1268d · 7f1268d
1 parent 902e9b3
commit 7f1268d
Showing 1 changed file with 1 addition and 1 deletion.
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
@@ -314,7 +314,7 @@ private CloseSafeProducer<K, V> doCreateTxProducer(String suffix, boolean isCons
 		Map<String, Object> configs = new HashMap<>(this.configs);
 		configs.put(ProducerConfig.TRANSACTIONAL_ID_CONFIG, this.transactionIdPrefix + suffix);
 		if (this.clientIdPrefix != null) {
-			newProducerConfigs.put(ProducerConfig.CLIENT_ID_CONFIG,
+			configs.put(ProducerConfig.CLIENT_ID_CONFIG,
 					this.clientIdPrefix + "-" + this.clientIdCounter.incrementAndGet());
 		}
 		producer = new KafkaProducer<K, V>(configs, this.keySerializer, this.valueSerializer);