Package org.nuxeo.lib.stream.log
The Log interface with Chronicle and Kafka implementation.
-
Interface Summary Interface Description LogAppender<M extends Externalizable> An appender is used to append message into a Log.LogConfig LogManager Manage Log and give access to Appenders and Tailers.LogOffset A message position in a partition.LogTailer<M extends Externalizable> Sequential reader for a partition or multiple partitions.RebalanceListener Listener to be notified on partition rebalancing. -
Class Summary Class Description AbstractLogConfig Latency Extends LogLag with lower and upper timestamps to express lag as a latency.LogLag Represent the number of messages between 2 offsetsLogPartition A tuple to store a Log name and the partition index.LogRecord<M extends Externalizable> A LogRecord contains the message and its offset.Name 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.NameResolver UnifiedLogManager -
Exception Summary Exception Description RebalanceException Exception raised duringLogTailer.read(Duration)
if there is a rebalancing.