Actually I create logs and writer through Namespace:
Namespace namespace = ...
if (!namespace.logExists(logName)) {
namespace.createLog(logName);
}
DistributedLogManager logManager = namespace.openLog(logName);
AsyncLogWriter asyncLogWriter =
FutureUtils.result(logManager.openAsyncLogWrite
On Tue, Feb 26, 2019 at 6:37 PM Lothruin Mirwen
wrote:
> Hi BookKeepers!
>
> I have an issue with DL LogReader.readNext(false) [ie: blocking]
>
> Such call should "block until return a record if there are records in the
> stream (aka catching up). Otherwise it would wait up to {@link
> Distribute
Hi BookKeepers!
I have an issue with DL LogReader.readNext(false) [ie: blocking]
Such call should "block until return a record if there are records in the
stream (aka catching up). Otherwise it would wait up to {@link
DistributedLogConfiguration#getReadAheadWaitTime()} milliseconds and return
nul
