qingzhongli
qingzhongli
@spinlock 谢谢您的回复，还有几个问题请教一下。 请问： 1、 pipeline 写出的操作的执行结果是否被及时读取了如何验证？可否详细的说一下方法？ 2、pipeline 满了的话，如何查看是否满了？ 3、我现在在 pipeline.sync() 这里加了异常捕获的逻辑，是否合理？
@spinlock 多谢指点。刚开始学着用，还想问一下： 1、两个thread的写法，能给个简单的参考吗？ 2、pipeline 写出过程的错误，怎么检查？
I got the same problem. As @dholm said , if I revert that commit https://github.com/confluentinc/librdkafka/commit/8e20e1ee79b188ae610aac3a2d2517f7f12dd890, the leaks go away.
> Seems we have incorrect filter logic in `NetUtils`. Yes. Perhaps there are three points that need adjustment, as follows: 1. The `isValidV6Address` method in the `NetUtils` class should support...