Class TrackerCommand
java.lang.Object
org.nuxeo.lib.stream.tools.command.Command
org.nuxeo.lib.stream.tools.command.TrackerCommand
Track consumer positions so they can be restored in case of fail-over
- Since:
- 10.1
-
Field Summary
Modifier and TypeFieldDescriptionprotected static final String
protected String
static final String
protected int
protected static final String
protected static final String
protected static final String
static final String
static final String
protected int
protected static final String
protected String
protected StreamProcessor
protected Topology
protected boolean
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptiongetLogNames
(LogManager manager, String names) protected void
initTopology
(LogManager manager) name()
boolean
run
(LogManager manager, org.apache.commons.cli.CommandLine cmd) protected boolean
runProcessor
(LogManager manager) void
updateOptions
(org.apache.commons.cli.Options options) Methods inherited from class org.nuxeo.lib.stream.tools.command.Command
getRecordCodec, getRecordRenderer
-
Field Details
-
COMPUTATION_NAME
- See Also:
-
INPUT_STREAM
- See Also:
-
INTERNAL_LOG_PREFIX
- See Also:
-
NAME
- See Also:
-
DEFAULT_INTERVAL
- See Also:
-
DEFAULT_COUNT
- See Also:
-
ALL_LOGS
- See Also:
-
DEFAULT_LATENCIES_LOG
- See Also:
-
verbose
protected boolean verbose -
output
-
logNames
-
interval
protected int interval -
count
protected int count -
topology
-
processor
-
codec
-
-
Constructor Details
-
TrackerCommand
public TrackerCommand()
-
-
Method Details