public EndlessConsumer<String, Integer> endlessConsumer(
KafkaConsumer<String, Integer> kafkaConsumer,
ExecutorService executor,
public EndlessConsumer<String, Integer> endlessConsumer(
KafkaConsumer<String, Integer> kafkaConsumer,
ExecutorService executor,