AC:
- a component running close to blazegraph should read the content produced in T251270 and update blazegraph
- this components should produce metrics:
- the lag similar to what we monitor with the current updater
- an approximation of the divergence (actual mutation count vs expect mutation count)
- some perf/sizing metrics (triples sent/time spent/...)
- this component should be able to resume its operations (kafka offsets/timestamp support)
- this component is expected to write to a single blazegraph instance (no H/A)