KafkaConsumer<String, String> kafkaConsumer,
ExecutorService executor,
Consumer<ConsumerRecord<String, String>> handler,
ApplicationProperties properties)
{
return
KafkaConsumer<String, String> kafkaConsumer,
ExecutorService executor,
Consumer<ConsumerRecord<String, String>> handler,
ApplicationProperties properties)
{
return