Skip to content

Commit dc28e2f

Browse files
committed
Fix JavaDocs for constants
1 parent 95ccdcb commit dc28e2f

File tree

2 files changed

+12
-4
lines changed

2 files changed

+12
-4
lines changed

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

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,11 +82,15 @@
8282
* @author Gary Russell
8383
* @author Murali Reddy
8484
* @author Nakul Mishra
85+
* @author Artem Bilan
8586
*/
8687
public class DefaultKafkaProducerFactory<K, V> implements ProducerFactory<K, V>, ApplicationContextAware,
8788
ApplicationListener<ContextStoppedEvent>, DisposableBean {
8889

89-
private static final Duration DEFAULT_PHYSICAL_CLOSE_TIMEOUT = Duration.ofSeconds(30);
90+
/**
91+
* The default close timeout duration as 30 seconds.
92+
*/
93+
public static final Duration DEFAULT_PHYSICAL_CLOSE_TIMEOUT = Duration.ofSeconds(30);
9094

9195
private static final Log logger = LogFactory.getLog(DefaultKafkaProducerFactory.class); // NOSONAR
9296

@@ -149,7 +153,7 @@ public void setValueSerializer(@Nullable Serializer<V> valueSerializer) {
149153

150154
/**
151155
* The time to wait when physically closing the producer (when {@link #stop()} or {@link #destroy()} is invoked).
152-
* Specified in seconds; default {@value #DEFAULT_PHYSICAL_CLOSE_TIMEOUT}.
156+
* Specified in seconds; default {@link #DEFAULT_PHYSICAL_CLOSE_TIMEOUT}.
153157
* @param physicalCloseTimeout the timeout in seconds.
154158
* @since 1.0.7
155159
*/

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

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -52,12 +52,16 @@
5252
* in the application context.
5353
*
5454
* @author Gary Russell
55+
* @author Artem Bilan
5556
*
5657
* @since 1.3
5758
*/
5859
public class KafkaAdmin implements ApplicationContextAware, SmartInitializingSingleton {
5960

60-
private static final Duration DEFAULT_CLOSE_TIMEOUT = Duration.ofSeconds(10);
61+
/**
62+
* The default close timeout duration as 10 seconds.
63+
*/
64+
public static final Duration DEFAULT_CLOSE_TIMEOUT = Duration.ofSeconds(10);
6165

6266
private static final int DEFAULT_OPERATION_TIMEOUT = 30;
6367

@@ -92,7 +96,7 @@ public void setApplicationContext(ApplicationContext applicationContext) throws
9296
}
9397

9498
/**
95-
* Set the close timeout in seconds. Defaults to {@value #DEFAULT_CLOSE_TIMEOUT} seconds.
99+
* Set the close timeout in seconds. Defaults to {@link #DEFAULT_CLOSE_TIMEOUT} seconds.
96100
* @param closeTimeout the timeout.
97101
*/
98102
public void setCloseTimeout(int closeTimeout) {

0 commit comments

Comments
 (0)