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 LogManagerManage Log and give access to Appenders and Tailers. LogOffsetA message position in a partition. LogTailer<M extends Externalizable>Sequential reader for a partition or multiple partitions. RebalanceListenerListener to be notified on partition rebalancing.
Class Summary Class Description AbstractLogConfig LatencyExtends LogLag with lower and upper timestamps to express lag as a latency. LogLagRepresent the number of messages between 2 offsets LogPartitionA tuple to store a Log name and the partition index. LogRecord<M extends Externalizable>A LogRecord contains the message and its offset. NameAn identifier composed of a namespace and a specific name with 2 string representations:
- an uniform resource name (urn) represented as a relative path:
- an identifier (id): encode the urn as
When there is no namespace, URN and id are identical.
Exception Summary Exception Description RebalanceExceptionException raised during
LogTailer.read(Duration)if there is a rebalancing.