0

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

4

1 回答 1

1

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

于 2016-06-03T23:07:03.353 回答