Skip to content

Commit a39e2ff

Browse files
committed
GH-3808: Applied review comments
1 parent 4c987a8 commit a39e2ff

File tree

2 files changed

+5
-3
lines changed

2 files changed

+5
-3
lines changed

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

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -104,6 +104,7 @@
104104
* @author Gurps Bassi
105105
* @author Valentina Armenise
106106
* @author Christian Fredriksson
107+
* @author Francois Rosiere
107108
*/
108109
public class KafkaTemplate<K, V> implements KafkaOperations<K, V>, ApplicationContextAware, BeanNameAware,
109110
ApplicationListener<ContextStoppedEvent>, DisposableBean, SmartInitializingSingleton {
@@ -468,9 +469,9 @@ public void setObservationRegistry(ObservationRegistry observationRegistry) {
468469
/**
469470
* Return the {@link ObservationRegistry} used by the template.
470471
* @return the observation registry
471-
* @since 3.3.5
472+
* @since 3.2.9
472473
*/
473-
public ObservationRegistry getObservationRegistry() {
474+
protected ObservationRegistry getObservationRegistry() {
474475
return this.observationRegistry;
475476
}
476477

@@ -545,7 +546,7 @@ private String getAdminBootstrapAddress() {
545546
/**
546547
* Return the cluster id, if available.
547548
* @return the cluster id.
548-
* @since 3.3.5
549+
* @since 3.2.9
549550
*/
550551
@Nullable
551552
protected String clusterId() {

spring-kafka/src/test/java/org/springframework/kafka/support/micrometer/ObservationTests.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -106,6 +106,7 @@
106106
* @author Wang Zhiyang
107107
* @author Christian Mergenthaler
108108
* @author Soby Chacko
109+
* @author Francois Rosiere
109110
*
110111
* @since 3.0
111112
*/

0 commit comments

Comments
 (0)