- .findById(tp.toString())
- .map(PartitionStatistics::new)
- .orElse(new PartitionStatistics(tp)));
+ .findById(Integer.toString(tp.partition()))
+ .orElse(new StatisticsDocument(tp.partition()));
+ consumer.seek(tp, document.offset);
+ seen.put(tp.partition(), document.statistics);