Couchbase nicht onComplete nach dem Senden von Daten anrufen

Question

Ich bin couchbase Mutationen durch Java-Code ähnlich wie Funktion in https://github.com/couchbase/couchbase-kafka-connector/blob/master/src/main/java/com/couchbase/kafka/CouchbaseReader.java. Wir abonnieren mit einem io Scheduler statt am Ende toBlocking. Wir bekommen Mutationen und streamEndMessages, aber wir kommen nie aufComplete. Daher wartet der Code nur bis zum Tod. Wir verwenden Core-io-1.2.6 und mit Top-of-Branch Core-io-1.3.0.

Answer 1

Diese Einschränkung ist im Moment bekannt, die in der nächsten Version behoben wird