- public EndlessConsumer<String, Message> endlessConsumer(
- Consumer<String, Message> kafkaConsumer,
- ExecutorService executor,
- ApplicationRebalanceListener rebalanceListener,
- ApplicationRecordHandler recordHandler,
- KafkaProperties kafkaProperties,
- ApplicationProperties applicationProperties)