couchbase - Couchbase がデータ送信後に onComplete を呼び出さない

Question

https://github.com/couchbase/couchbase-kafka-connector/blob/master/src/main/java/com/couchbase/kafka/CouchbaseReader.javaの実行機能に似たJavaコードを介してcouchbaseミューテーションを取得しています。最後に toBlocking の代わりに io スケジューラーでサブスクライブします。Mutation と streamEndMessages を取得しますが、onComplete を取得することはありません。したがって、コードは殺されるまで待機します。core-io-1.2.6 を使用し、core-io-1.3.0 のブランチのトップを使用します。