如何解决反应堆通量抛出llegalArgumentException-由于bufferTimeout而怀疑
buildPipeline(). // returns a flux based on changeStreamEvents or Kafka receives
.bufferTimeout( capacity,Duration.ofSeconds(1))
. flatMap( r -> {
element x = r.get(r.size()-1)
//some processing on element and the batch obtained
})
.doOnError( e-> log.info("error occurred:" + e.toString())
.subscribe()
但是,我看到我的应用程序出现了以下错误-
java.lang.illegalArgumentException:3.9 While the Subscription is not cancelled,Subscription.request(long n) MUST throw a java.lang.illegalArgumentException if argument <= 0
at com.mongodb.reactivestreams.client.internal.ObservabletoPublisher$1
$1.request(ObservabletoPublisher.java:43)
at reactor.core.publisher.FluxMap$MapSubscriber.request(FluxMap.java:155)
at reactor.core.publisher.FluxBufferTimeout
$BufferimeoutSubscriber.requestMore(FluxBufferTimeout.java:317)
我无法确定出什么问题以及为什么流因此错误而终止。 任何帮助将不胜感激。
在我添加“ bufferTimeout”以添加批处理功能之后,应用程序开始引发此错误。在此之前,我从未遇到过这种异常。 也不确定如何复制问题,因为它不是在本地或UAT中发生,而仅在应用程序的生产环境中发生。 任何线索都将有所帮助。
谢谢!
解决方法
尝试添加onBackPressureBuffer(),以便在需求较低的情况下,该运算符缓冲请求并以受控方式发出项目。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。