import java.util.Optional;
import java.util.Properties;
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
@SpringBootApplication
return new KafkaConsumer<>(props);
}
- @Bean(destroyMethod = "shutdown")
- ExecutorService executorService()
- {
- return Executors.newFixedThreadPool(1);
- }
-
@Bean(destroyMethod = "shutdown")
TransferConsumer transferConsumer(
TransferServiceProperties properties,
KafkaConsumer<String, String> consumer,
- ExecutorService executorService,
ObjectMapper mapper,
TransferService productionTransferService,
TransferService restoreTransferService)
new TransferConsumer(
properties.topic,
consumer,
- executorService,
mapper,
new TransferConsumer.ConsumerUseCases() {
@Override