Page MenuHomePhabricator

Store Kafka poller position data in the WDQS database
Closed, ResolvedPublic

Description

Right now, Kafka poller when Updater starts uses timestamp to re-sync with the data stream. While this is the only way to go for dumps, if we're restarting from Kafka polling, we could preserve the current Kafka position and start with it when possible.

Event Timeline

Restricted Application added a subscriber: Aklapper. · View Herald Transcript
Smalyshev triaged this task as Medium priority.Apr 24 2018, 9:11 PM

Change 421348 had a related patch set uploaded (by Smalyshev; owner: Smalyshev):
[wikidata/query/rdf@master] Store Kafka offsets in the DB

https://gerrit.wikimedia.org/r/421348

Change 421348 merged by jenkins-bot:
[wikidata/query/rdf@master] Store Kafka offsets in the DB

https://gerrit.wikimedia.org/r/421348