- Integer partition = tp.partition();
- StatisticsDocument document =
- partitionStatisticsRepository
- .findById(partition.toString())
- .orElse(new StatisticsDocument(partition));
- document.offset = offset;
- partitionStatisticsRepository.save(document);