Package org.nuxeo.lib.stream.log

The Log interface with Chronicle and Kafka implementation.

See: Description

Interface Summary

Interface	Description
LogAppender<M extends Externalizable>	An appender is used to append message into a Log.
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
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.

Exception Summary

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

Package org.nuxeo.lib.stream.log Description

The Log interface with Chronicle and Kafka implementation.