import org.springframework.context.annotation.Configuration;
import java.util.Properties;
+import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@Bean
public EndlessConsumer endlessConsumer(
KafkaConsumer<String, String> kafkaConsumer,
+ ExecutorService executor,
ApplicationProperties properties)
{
- EndlessConsumer consumer =
+ return
new EndlessConsumer(
- Executors.newFixedThreadPool(1),
+ executor,
properties.getClientId(),
properties.getTopic(),
kafkaConsumer);
+ }
- consumer.start();
-
- return consumer;
+ @Bean
+ public ExecutorService executor()
+ {
+ return Executors.newSingleThreadExecutor();
}
@Bean(destroyMethod = "close")