ExecutorService executor;
@Autowired
PartitionStatisticsRepository repository;
- @Autowired
+ @Autowired
+ WordcountRebalanceListener wordcountRebalanceListener;
+ @Autowired
WordcountRecordHandler wordcountRecordHandler;
EndlessConsumer<String, String> endlessConsumer;
properties.getClientId(),
properties.getTopic(),
kafkaConsumer,
+ wordcountRebalanceListener,
captureOffsetAndExecuteTestHandler);
endlessConsumer.start();