Details
-
Bug
-
Resolution: Fixed
-
Major
-
None
-
None
-
1
Description
The virtual bucket UUID should be included in the saved offset, and used to resume streaming.
Borrow this code (from the Elasticsearch connector) that properly initializes a partitions's failover log with the correct vbuuid:
ps.setFailoverLog(singletonList(new FailoverLogEntry(-1L, checkpoint.getVbuuid())));
|
Attachments
Issue Links
- depends on
-
KAFKAC-118 Source: vBucketUuid may be incorrect
- Resolved
- is duplicated by
-
KAFKAC-123 Source: Include vbucket uuid in saved offset
- Resolved
For Gerrit Dashboard: KAFKAC-161 | ||||||
---|---|---|---|---|---|---|
# | Subject | Branch | Project | Status | CR | V |
119741,4 | KAFKAC-118 Source: vBucketUuid may be incorrect KAFKAC-161 Should include vBucket UUID in saved offset | master | kafka-connect-couchbase | Status: MERGED | +2 | +1 |