Package org.nuxeo.lib.stream.tools.command
package org.nuxeo.lib.stream.tools.command
-
ClassDescriptionAppends records from a dump file into an a Log partition.Output records to stdout.Copy a Log to anotherMonitors consumer latencies to Datadog.Dump records from a Log into an Avro file.Display the current lags of consumers.Display the current latencies of consumers.A computation that sends periodically latencies to Datadog.A computation that sends periodically latencies to graphite.A computation that sends periodically latencies information into a Log.Monitors consumer latencies to graphiteManipulates the consumer position to the beginning, end or a specific timestampRestore consumer positions using the latency tracker Log.Output the last records on a Log.Track consumer positions so they can be restored in case of fail-overOutput information of Work in a StreamWorkManager Queue.