@Bean
public ApplicationRebalanceListener rebalanceListener(
+ KafkaConsumer<String, String> kafkaConsumer,
ApplicationRecordHandler recordHandler,
AdderResults adderResults,
StateRepository stateRepository,
ApplicationProperties properties)
{
return new ApplicationRebalanceListener(
+ kafkaConsumer,
recordHandler,
adderResults,
stateRepository,