Skip to content

Commit 83a34b9

Browse files
refactor util class (#4197)
* refactor util class * refactor remove unnecessary generic signatures Signed-off-by: moonyoungCHAE <xpf_fl@naver.com>
1 parent a0b5b70 commit 83a34b9

File tree

2 files changed

+6
-3
lines changed

2 files changed

+6
-3
lines changed

spring-kafka/src/main/java/org/springframework/kafka/config/KafkaListenerConfigUtils.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,10 @@
2323
* @author Gary Russell
2424
* @author Tomaz Fernandes
2525
*/
26-
public abstract class KafkaListenerConfigUtils {
26+
public final class KafkaListenerConfigUtils {
27+
28+
private KafkaListenerConfigUtils() {
29+
}
2730

2831
/**
2932
* The bean name of the internally managed Kafka listener annotation processor.

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -103,7 +103,7 @@ public static <K, V> KafkaResourceHolder<K, V> getTransactionalResourceHolder(
103103
throw e;
104104
}
105105

106-
resourceHolder = new KafkaResourceHolder<K, V>(producer, closeTimeout);
106+
resourceHolder = new KafkaResourceHolder<>(producer, closeTimeout);
107107
bindResourceToTransaction(resourceHolder, producerFactory);
108108
}
109109
return resourceHolder;
@@ -121,7 +121,7 @@ private static <K, V> void bindResourceToTransaction(KafkaResourceHolder<K, V> r
121121
resourceHolder.setSynchronizedWithTransaction(true);
122122
if (TransactionSynchronizationManager.isSynchronizationActive()) {
123123
TransactionSynchronizationManager
124-
.registerSynchronization(new KafkaResourceSynchronization<K, V>(resourceHolder, producerFactory));
124+
.registerSynchronization(new KafkaResourceSynchronization<>(resourceHolder, producerFactory));
125125
}
126126
}
127127

0 commit comments

Comments
 (0)