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