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 offsets
LogPartition	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 as namespace-name When there is no namespace, URN and id are identical.
NameResolver
UnifiedLogManager

Exception Summary

Exception	Description
RebalanceException	Exception raised during LogTailer.read(Duration) if there is a rebalancing.