{
return new WordcountRecordHandler(
repository,
- properties.getClientId(),
properties.getTopic(),
Clock.systemDefaultZone(),
properties.getCommitInterval(),
@Bean
public WordcountRebalanceListener wordcountRebalanceListener(
- WordcountRecordHandler wordcountRecordHandler)
+ WordcountRecordHandler wordcountRecordHandler,
+ PartitionStatisticsRepository repository,
+ Consumer<String, String> consumer,
+ ApplicationProperties properties)
{
- return new WordcountRebalanceListener(wordcountRecordHandler);
+ return new WordcountRebalanceListener(
+ wordcountRecordHandler,
+ repository,
+ properties.getClientId(),
+ consumer);
}
@Bean