currentSequenceNumbers() is missing vBuckets

https://github.com/couchbase/couchbase-kafka-connector/issues/10

Apologies if duplicate. Please also close on Github when fixed.
—
legatoslide commented on Jan 9

Hello,

when I call the currentSequenceNumbers() of the CouchbaseKafkaConnector class, I get:

1024 MutationTokens if only 1 node in the cluster
512 if 2 nodes
341 if 3 nodes So it seems we only get 1/N MutationTokens with N the number of nodes of the cluster.
As far as I can see, this is what we get from the Core IO library.

Regards,
David
@legatoslidelegatoslide closed this 6 days ago
@legatoslide
legatoslide commented 6 days ago
Hello,

-oups, closed issue by mistake-

any news on this? It prevents from correctly starting from current state as we can not retrieve all sequence numbers for each one of the vbuckets.

Regards,
David