Change Details

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 operation (kafka offsets/timestamp support) - this component is expected to write to a single blazegraph instance (no H/A)

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)

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)