Details
-
Bug
-
Resolution: Fixed
-
Major
-
1.2.1
-
None
Description
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