KafkaConsumer<String, String> kafkaConsumer,
ApplicationProperties properties)
{
KafkaConsumer<String, String> kafkaConsumer,
ApplicationProperties properties)
{
new EndlessConsumer(
Executors.newFixedThreadPool(1),
properties.getClientId(),
properties.getTopic(),
kafkaConsumer);
new EndlessConsumer(
Executors.newFixedThreadPool(1),
properties.getClientId(),
properties.getTopic(),
kafkaConsumer);