repository
.findById(Integer.toString(partition))
.orElse(new StatisticsDocument(partition));
- consumer.seek(tp, document.offset);
+ if (document.offset >= 0)
+ {
+ // Only seek, if a stored offset was found
+ // Otherwise: Use initial offset, generated by Kafka
+ consumer.seek(tp, document.offset);
+ }
seen.put(partition, document.statistics);
});
}