Ошибка разъема кафки при анализе данных из Couchbase ⇐ JAVA

[Anonymous]

Я определил разъем Kafka с помощью Couchbasasourceconnector. В конфигурации я не указал никаких разделов как таковой, однако, когда работает разъем, я получаю следующую ошибку < /p>

Код: Выделить всё

java.lang.IllegalArgumentException: Malformed ClosedIntRange. Expected integer or lower..upper but got 0,1,2,3,...1023
couchbase.client.dcp.util.partitionSet$ClosedIntRange.parse(PartitionSet.java:88)

Я попытался определить couchbase.partitioning в конфигурации соединителя, но он не работал

Подробнее здесь: https://stackoverflow.com/questions/796 ... -couchbase