kafkaproducer0.10.0.0,javadoc声明应该抛出bufferexhaustedexception

mm9b1k5b  于 2021-06-07  发布在  Kafka
关注(0)|答案(0)|浏览(276)

我目前正在研究一个kafka集成,查看send javadoc它为kafkaproducer的send api声明了以下内容:
@抛出bufferexhaustedexception,如果 block.on.buffer.full=false 缓冲区满了。
但是,查看0.10.0.0代码时,我找不到实际抛出此异常的位置,因此在我看来,我必须将max.block.ms设置为0,并期望改为timeoutexception,以便以非阻塞方式工作。
下面是版本0.8.2.1中bufferpool类的一个片段。我们可以清楚地看到,如果没有可用内存,将引发bufferexhaustedexception:
0.8.2.1代码段
另一方面,在版本0.10.0.0中,代码如下:
0.10.0.0代码段
我所说的前进方向应该是将max.block.ms设置为0并期望timeoutexception,还是bufferexhaustedexception仍然受支持?
如果不再支持bufferexhaustedexception,则至少应该将其从SendAPI的javadoc中删除。
谢谢。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题