发送数据后 Couchbase 未调用 onComplete答案

【问题标题】：Couchbase not calling onComplete after sending data发送数据后 Couchbase 未调用 onComplete
【发布时间】：2016-10-03 17:35:42
【问题描述】：

我正在通过类似于 https://github.com/couchbase/couchbase-kafka-connector/blob/master/src/main/java/com/couchbase/kafka/CouchbaseReader.java 中的 run 函数的 java 代码获取 couchbase 突变。最后我们使用 io 调度程序而不是 toBlocking 订阅。我们得到了 mutation 和 streamEndMessages，但我们从来没有得到 onComplete。因此，代码只是等到被杀死。我们使用 core-io-1.2.6，并使用顶部分支 core-io-1.3.0。

【问题讨论】：

【解决方案1】：

这是目前已知的限制，将在下一个版本中修复

【讨论】：