Skip to content

Commit 54d83f3

Browse files
committed
1 parent 678a21b commit 54d83f3

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

spring-kafka/src/main/java/org/springframework/kafka/core/DefaultKafkaProducerFactory.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -125,7 +125,7 @@ public void setValueSerializer(Serializer<V> valueSerializer) {
125125

126126
/**
127127
* The time to wait when physically closing the producer via the factory rather than
128-
* closing the producer itself (when {@link #reset()}, {@link #destroy() or
128+
* closing the producer itself (when {@link #destroy() or
129129
* #closeProducerFor(String)} are invoked). Specified in seconds; default
130130
* {@link #DEFAULT_PHYSICAL_CLOSE_TIMEOUT}.
131131
* @param physicalCloseTimeout the timeout in seconds.

spring-kafka/src/main/java/org/springframework/kafka/transaction/KafkaTransactionManager.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@
4444
*
4545
* <p>
4646
* Application code is required to retrieve the transactional Kafka resources via
47-
* {@link ProducerFactoryUtils#getTransactionalResourceHolder(ProducerFactory, java.time.Duration)}.
47+
* {@link ProducerFactoryUtils#getTransactionalResourceHolder}.
4848
* Spring's {@link org.springframework.kafka.core.KafkaTemplate KafkaTemplate} will auto
4949
* detect a thread-bound Producer and automatically participate in it.
5050
*
@@ -71,7 +71,7 @@ public class KafkaTransactionManager<K, V> extends AbstractPlatformTransactionMa
7171

7272
private final ProducerFactory<K, V> producerFactory;
7373

74-
private final long closeTimeout = DEFAULT_CLOSE_TIMEOUT;
74+
private long closeTimeout = DEFAULT_CLOSE_TIMEOUT;
7575

7676
/**
7777
* Create a new KafkaTransactionManager, given a ConnectionFactory.
@@ -101,7 +101,7 @@ public ProducerFactory<K, V> getProducerFactory() {
101101
* @since 1.3.11
102102
*/
103103
public void setCloseTimeout(long closeTimeout) {
104-
setCloseTimeout(closeTimeout);
104+
this.closeTimeout = closeTimeout;
105105
}
106106

107107
@Override

0 commit comments

Comments
 (0)