Affects Version/s: None
Fix Version/s: 3.4.6
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:
|For Gerrit Dashboard: KAFKAC-161|
|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|