Package org.nuxeo.lib.stream.log
package org.nuxeo.lib.stream.log
The Log interface with In-Memory and Kafka implementation.
-
ClassDescriptionExtends LogLag with lower and upper timestamps to express lag as a latency.LogAppender<M extends Externalizable>An appender is used to append message into a Log.Represent the number of messages between 2 offsetsManage Log and give access to Appenders and Tailers.A message position in a partition.A tuple to store a Log name and the partition index.LogRecord<M extends Externalizable>A LogRecord contains the message and its offset.LogTailer<M extends Externalizable>Sequential reader for a partition or multiple partitions.An identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:namespace/name
- an identifier (id): encode the urn asnamespace-name
When there is no namespace, URN and id are identical.Exception raised duringLogTailer.read(Duration)if there is a rebalancing.Listener to be notified on partition rebalancing.