@Autowired
ExecutorService executor;
@Autowired
- KeyCountingRebalanceListener keyCountingRebalanceListener;
- @Autowired
KeyCountingRecordHandler keyCountingRecordHandler;
EndlessConsumer<String, Long> endlessConsumer;
properties.getClientId(),
properties.getTopic(),
kafkaConsumer,
- keyCountingRebalanceListener,
captureOffsetAndExecuteTestHandler);
endlessConsumer.start();