0

我有弹簧远程分块在 JMS 上工作。我的配置如下。

网关等待超时=5000ms,提交间隔=10,每次读取可以读取的记录数为1000。

并发消费者和最大并发消费者分别为 20 和 30。

油门限制为 5。

按照上面的配置,reader读取70k条记录并停止,等待slave处理读取的item,

问题是当需要读取的总记录为 225k 时,为什么它会停止在 70K?

将提交间隔更改为 2,将每次读取的记录数更改为 500,将总读取更改为 14k,知道吗?

作业状态保持为 STARTED

我在这里先向您的帮助表示感谢

4

1 回答 1

-2

将 ActiveMQ 用于远程块时,我遇到了类似的问题。但是使用kafka没有问题。

于 2017-03-09T08:17:49.457 回答