- return new WordcountRebalanceListener(
- wordcountRecordHandler,
- repository,
- properties.getClientId(),
- properties.getTopic(),
- Clock.systemDefaultZone(),
- properties.getCommitInterval(),
- consumer);
+ return new KeyCountingRebalanceListener(
+ keyCountingRecordHandler,
+ properties.getClientId());