chronicle-queue

    2热度

    1回答

    对于恢复的概念,我需要将数据从一个记录队列复制到另一个。 将一个队列中的整个Bytes对象直接复制到另一个队列中是否安全? 类似 documentContext()。电线()。字节()。读(byte_buffer) ,然后包裹此byte_buffer成byte_store和写入作为 documentContext()。电线( ).bytes()。写(byte_Store)。 我这样做的原因是避免任

    1热度

    1回答

    以下代码在第20次迭代的第二个assert语句上失败 - 注意我只是重新创建了导致问题的代码;计数不相关,而是写入的字节数是。 SingleChronicleQueue writer = SingleChronicleQueueBuilder.binary("/tmp/broken").build(); ExcerptAppender excerptAppender = writer.

    1热度

    1回答

    我们在低延迟应用程序(在Linux Centos机器上)使用Vanilla Chronicle队列,版本3.6.0。我们的客户报告说,有一天,我们的客户报告在应用程序中缺乏响应2.5秒(我们已经运行了很多个月,但没有发生这种情况)。我们在延迟时间检查了文件的顶部,并看到当时进程正在运行flush命令。 (截屏来自顶上如下公布。) 大家都在猜测,该O/S刷新纪事内存页到磁盘,这阻碍了我们的处理线程持

    0热度

    1回答

    从Chronicle-Queue v4.5.27开始,似乎ServiceWrapperBuilder需要增强以包含StoreFileListener分配?如果有不同的构造,再次,通过ServiceWrapper队列创建,它是什么?

    2热度

    1回答

    我发现maven central的chronicle-queue版本已经很老了:4.5.27,而4.6.23是github上最新发布的版本。这是否意味着4.5.27是一种“prod-ready”,而所有4.5.27+都是实验性的?或者您使用其他存储库进行分发?

    2热度

    1回答

    嗨,我是编年史产品的新用户,直到现在文档/用法看起来相当顺利。 虽然我有一个问题,当Map数据在同一主机上的JVM之间共享时,消费者JVM等待数据时会收到任何类型的回调或信号,或者我们需要实现自定义回调机制。 想法?

    2热度

    1回答

    我打算使用编年史4(SingleChronicleQueue)的IPC。我使用编年史前3(IndexedQueue),它不是线程安全的,我用来创建多个队列每个线程,但我被告诉某人通过使用SingleChronicleQueue我可以使用1队列JVM中的所有线程。 但是,如果2个不同的进程试图在同一个编年史队列中并发写入,它会很好吗? 这是建议做或为不同的过程,我需要创建不同的队列。

    1热度

    1回答

    我们将事件存储在Chronicle队列V4中,并有一个Tailer来处理它们。其中一些事件过期(不是基于时间的,但是被后来的事件所取代),因此可以在处理过程中跳过。 有没有办法更新现有的摘录,即设置一个布尔标志“过期”为真,所以我们可以跳过过期的事件?还是有另一种解决方案来实现Chronicle队列? 例如,系统生成事件A1,B1和C1。现在事件B2到达,使B1过时。我们现在可以在没有昂贵处理的情

    2热度

    2回答

    我正在尝试将Chronicle Queue实现到我们的系统中,并且每天都有一个关于文件滚动的问题,但是在特定的时间根据当地时区的流程。我读了几篇关于如何指定滚动周期的文章,但根据文档说明,纪元时间按UTC的午夜时间工作。我需要做些什么来配置滚动周期让我们说每天在运行过程的当地时区下午5点?有什么建议么? public class TestRollCycle { public class

    2热度

    1回答

    我有一个在java上实现的侦听器项目,它使用来自kafka的数据并将其推入到Vanilla Chronicle队列中。我正在使用jna,jna-platform版本4.4.0和编年史队列版本3.6.4的java库。当我在Windows上运行项目时,它成功地消耗并将数据推入队列。但是,当我在位于Azure VM上的“Ubuntu 16.04.3 LTS”上运行它时,将数据推入队列时失败。另外,当我在