Package | Description |
---|---|
org.nuxeo.lib.stream.log |
The Log interface with Chronicle and Kafka implementation.
|
org.nuxeo.lib.stream.log.chronicle | |
org.nuxeo.lib.stream.log.kafka | |
org.nuxeo.lib.stream.tools.command |
Modifier and Type | Method and Description |
---|---|
default LogLag |
LogManager.getLag(String name,
String group)
Returns the lag between consumer
group and producers for a Log. |
static LogLag |
LogLag.of(long lag) |
static LogLag |
LogLag.of(long lowerOffset,
long upperOffset) |
Modifier and Type | Method and Description |
---|---|
List<LogLag> |
LogManager.getLagPerPartition(String name,
String group)
Returns the lag between consumer
group and the producers for each partition. |
Modifier and Type | Method and Description |
---|---|
protected LogLag |
ChronicleLogManager.getLagForPartition(String name,
int partition,
String group) |
Modifier and Type | Method and Description |
---|---|
List<LogLag> |
ChronicleLogManager.getLagPerPartition(String name,
String group) |
Modifier and Type | Method and Description |
---|---|
List<LogLag> |
KafkaLogManager.getLagPerPartition(String name,
String group) |
Modifier and Type | Method and Description |
---|---|
protected void |
LagCommand.renderLag(String group,
LogLag lag) |
Copyright © 2018 Nuxeo. All rights reserved.