Couchbase не вызывает onComplete после отправки данных

Question

Я получаю мутации couchbase через код java, аналогичный функции run в https://github.com/couchbase/couchbase-kafka-connector/blob/master/src/main/java/com/couchbase/kafka/CouchbaseReader.java. Мы подписываемся с io-планировщиком вместо toBlocking в конце. Мы получаем мутации и streamEndMessages, но никогда не получаем onComplete. Следовательно, код просто ждет, пока его не убьют. Мы используем core-io-1.2.6 и верхнюю часть ветки core-io-1.3.0.

Answer 1

Это известное ограничение на данный момент, которое будет исправлено в следующей версии