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.renderer |
Modifier and Type | Method and Description |
---|---|
LogRecord<M> |
LogTailer.read(Duration timeout)
Read a message from assigned partitions within the timeout.
|
Modifier and Type | Method and Description |
---|---|
protected LogRecord<M> |
ChronicleLogTailer.read() |
protected LogRecord<M> |
ChronicleCompoundLogTailer.read() |
LogRecord<M> |
ChronicleLogTailer.read(Duration timeout) |
LogRecord<M> |
ChronicleCompoundLogTailer.read(Duration timeout) |
Modifier and Type | Method and Description |
---|---|
LogRecord<M> |
KafkaLogTailer.read(Duration timeout) |
Modifier and Type | Method and Description |
---|---|
void |
TextRenderer.accept(LogRecord<Record> record) |
void |
MarkdownRenderer.accept(LogRecord<Record> record) |
Copyright © 2018 Nuxeo. All rights reserved.