Merge branch 'rebalance-listener' into stored-state
[demos/kafka/training] / src / main / java / de / juplo / kafka / PartitionStatisticsRepository.java
1 package de.juplo.kafka;
2
3 import org.springframework.data.mongodb.repository.MongoRepository;
4
5 import java.util.Optional;
6
7
8 public interface PartitionStatisticsRepository extends MongoRepository<StatisticsDocument, String>
9 {
10   public Optional<StatisticsDocument> findById(String partition);
11 }