KafkaConsumer<String, String> kafkaConsumer,
ApplicationProperties properties)
{
- EndlessConsumer consumer =
+ return
new EndlessConsumer(
Executors.newFixedThreadPool(1),
properties.getClientId(),
properties.getTopic(),
kafkaConsumer);
-
- consumer.start();
-
- return consumer;
}
@Bean(destroyMethod = "close")