@Bean
- public EndlessConsumer consumer()
+ public EndlessConsumer consumer(PartitionStatisticsRepository repository)
{
Assert.hasText(properties.getBootstrapServer(), "consumer.bootstrap-server must be set");
Assert.hasText(properties.getGroupId(), "consumer.group-id must be set");
EndlessConsumer consumer =
new EndlessConsumer(
Executors.newFixedThreadPool(1),
+ repository,
properties.getBootstrapServer(),
properties.getGroupId(),
properties.getClientId(),