See: Description
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 | Description |
---|---|
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 | Description |
---|---|
RebalanceException |
Exception raised during
LogTailer.read(Duration) if there is a rebalancing. |
Copyright © 2018 Nuxeo. All rights reserved.