Couchbase 在发送数据后不调用 onComplete
Couchbase not calling onComplete after sending data
我正在通过类似于 https://github.com/couchbase/couchbase-kafka-connector/blob/master/src/main/java/com/couchbase/kafka/CouchbaseReader.java 中的 运行 函数的 java 代码获取 couchbase 突变。我们订阅了一个 io scheduler 而不是最后的 toBlocking。我们得到突变和 streamEndMessages 但我们永远不会得到 onComplete。因此代码只是等到被杀死。
我们使用 core-io-1.2.6，并在分支 core-io-1.3.0.
的顶部
这是目前已知的限制，将在下一个版本中修复
我正在通过类似于 https://github.com/couchbase/couchbase-kafka-connector/blob/master/src/main/java/com/couchbase/kafka/CouchbaseReader.java 中的 运行 函数的 java 代码获取 couchbase 突变。我们订阅了一个 io scheduler 而不是最后的 toBlocking。我们得到突变和 streamEndMessages 但我们永远不会得到 onComplete。因此代码只是等到被杀死。 我们使用 core-io-1.2.6，并在分支 core-io-1.3.0.
的顶部这是目前已知的限制，将在下一个版本中修复