currentSequenceNumbers() is missing vBuckets

[legatoslide]

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

[legatoslide]

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