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