File tree 1 file changed +5
-6
lines changed
spring-kafka/src/main/java/org/springframework/kafka/config
1 file changed +5
-6
lines changed Original file line number Diff line number Diff line change @@ -319,18 +319,17 @@ public void stop(Runnable callback) {
319
319
}
320
320
}
321
321
322
- @ SuppressWarnings ("deprecation" )
323
322
@ Override
324
323
public synchronized void start () {
325
324
if (!this .running ) {
326
325
try {
327
326
Assert .state (this .properties != null ,
328
327
"streams configuration properties must not be null" );
329
- Topology topology = getObject ().build (this .properties ); // NOSONAR: getObject() cannot return null
330
- this .infrastructureCustomizer .configureTopology (topology );
331
- this .topology = topology ;
332
- LOGGER .debug (() -> topology .describe ().toString ());
333
- this .kafkaStreams = new KafkaStreams (topology , this .properties , this .clientSupplier );
328
+ Topology topol = getObject ().build (this .properties ); // NOSONAR: getObject() cannot return null
329
+ this .infrastructureCustomizer .configureTopology (topol );
330
+ this .topology = topol ;
331
+ LOGGER .debug (() -> topol .describe ().toString ());
332
+ this .kafkaStreams = new KafkaStreams (topol , this .properties , this .clientSupplier );
334
333
this .kafkaStreams .setStateListener (this .stateListener );
335
334
this .kafkaStreams .setGlobalStateRestoreListener (this .stateRestoreListener );
336
335
if (this .streamsUncaughtExceptionHandler != null ) {
You can’t perform that action at this time.
0 commit comments