@Autowired
ExecutorService executor;
@Autowired
+ ApplicationRebalanceListener rebalanceListener;
+ @Autowired
ApplicationRecordHandler recordHandler;
EndlessConsumer<String, Long> endlessConsumer;
properties.getClientId(),
properties.getTopic(),
kafkaConsumer,
+ rebalanceListener,
captureOffsetAndExecuteTestHandler);
endlessConsumer.start();