FolkMQ v1.7.8

消息大小与自动分片

folkmq 的消息超过 16M 时,会自动分片。如果要控制分片大小?

MqClient client = FolkMQ.createClient("folkmq://127.0.0.1:18602")
                .nameAs("demoapp")
                .config(c -> c.fragmentSize(1024*1024*16)) //默认为16m(一般会调得更小)
                .connect();