diff --git a/src/main/java/com/example/batchconsumer/FooBatchConsumerConfig.java b/src/main/java/com/example/batchconsumer/FooBatchConsumerConfig.java index a42b237..308e218 100644 --- a/src/main/java/com/example/batchconsumer/FooBatchConsumerConfig.java +++ b/src/main/java/com/example/batchconsumer/FooBatchConsumerConfig.java @@ -43,7 +43,7 @@ public ConcurrentKafkaListenerContainerFactory kafkaFooBatchCons } @Bean - public FooBatchListener stoppableFooListener( + public FooBatchListener fooBatchListener( final FooBatchSolver batchFooSolver ) { return new FooBatchListener(batchFooSolver);