Merge branch 'rebalance-listener' into stored-state

[demos/kafka/training] / src / main / java / de / juplo / kafka / PartitionStatisticsRepository.java

package de.juplo.kafka;

import org.springframework.data.mongodb.repository.MongoRepository;

import java.util.Optional;


public interface PartitionStatisticsRepository extends MongoRepository<StatisticsDocument, String>
{
  public Optional<StatisticsDocument> findById(String partition);
}