Skip to content

Commit bf36c64

Browse files
authored
KafkaStreamsDefConfig: Remove unused configuredBy
* fixed spacing in dead letter publishing failed message. * removed unused `configuredBy` set
1 parent e6bd735 commit bf36c64

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

spring-kafka/src/main/java/org/springframework/kafka/annotation/KafkaStreamsDefaultConfiguration.java

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -16,9 +16,6 @@
1616

1717
package org.springframework.kafka.annotation;
1818

19-
import java.util.HashSet;
20-
import java.util.Set;
21-
2219
import org.springframework.beans.factory.ObjectProvider;
2320
import org.springframework.beans.factory.UnsatisfiedDependencyException;
2421
import org.springframework.beans.factory.annotation.Qualifier;
@@ -72,11 +69,7 @@ public StreamsBuilderFactoryBean defaultKafkaStreamsBuilder(
7269
KafkaStreamsConfiguration streamsConfig = streamsConfigProvider.getIfAvailable();
7370
if (streamsConfig != null) {
7471
StreamsBuilderFactoryBean fb = new StreamsBuilderFactoryBean(streamsConfig);
75-
Set<StreamsBuilderFactoryBeanConfigurer> configuredBy = new HashSet<>();
76-
configurerProvider.orderedStream().forEach(configurer -> {
77-
configurer.configure(fb);
78-
configuredBy.add(configurer);
79-
});
72+
configurerProvider.orderedStream().forEach(configurer -> configurer.configure(fb));
8073
return fb;
8174
}
8275
else {

0 commit comments

Comments
 (0)