猿问

Chronicle Consumer 没有正确读取记录?

我正在使用编年史队列(5.16.13)将 json 值写入和读取到编年史文件。要编写对象,我在循环中使用以下内容


try (final DocumentContext dc = appender.writingDocument()) {

        dc.wire().write(() -> "msg").text("Hallo asdf");

        System.out.println("your data was store to index="+ dc.index());

        return true;

    } catch (Exception e) {

        logger.warn("Unable to store value to chronicle", e);

        return false;

    }

并阅读项目我在循环中执行以下调用


DocumentContext documentContext;

    do {

        documentContext = tailer.readingDocument();

        currentOffset = documentContext.index();

        System.out.println("Current offset: " + currentOffset);

    } while (!documentContext.isData());

我观察到的是变量currentOffset没有改变,一段时间后(似乎取决于有效载荷大小)循环无限大,当前偏移量具有疯狂的值。第一个循环的输出(缩短)是


Writing 0

your data was store to index=76385993359360

Writing 1

your data was store to index=76385993359361

Writing 2

your data was store to index=76385993359362

Writing 3

your data was store to index=76385993359363

Writing 4

your data was store to index=76385993359364

Writing 5

your data was store to index=76385993359365

Writing 6

your data was store to index=76385993359366

Writing 7

your data was store to index=76385993359367

Writing 8

your data was store to index=76385993359368

Writing 9

your data was store to index=76385993359369

Writing 10

your data was store to index=76385993359370

Writing 11


动漫人物
浏览 140回答 2
2回答
随时随地看视频慕课网APP

相关分类

Java
我要回答