File tree Expand file tree Collapse file tree 1 file changed +1
-8
lines changed
spring-kafka/src/main/java/org/springframework/kafka/annotation Expand file tree Collapse file tree 1 file changed +1
-8
lines changed Original file line number Diff line number Diff line change 1616
1717package org .springframework .kafka .annotation ;
1818
19- import java .util .HashSet ;
20- import java .util .Set ;
21-
2219import org .springframework .beans .factory .ObjectProvider ;
2320import org .springframework .beans .factory .UnsatisfiedDependencyException ;
2421import 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 {
You can’t perform that action at this time.
0 commit comments