Pulsar异步生产消息,出现丢失

2.8.1版本的pulsar,为了避免反复创建生产者连接,用while循环异步发送消息,发现当while超过1000左右的时候,会出现消息丢失的情况。比如我发送2000条,就会有几十条丢失,消费者消费不到。这块可能原因是什么吗?

将生产者客户端升为2.10.2版本,能有一定效果,但是还是会出现消息丢失的情况,无法确定具体原因,怀疑是队列阻塞,但未发现相应的报错信息