In run() method, if the fetchGenerationMetadata() or getGenerationId() fails, it crashes the entire Master and it doesn't try to retry.
There should be some retry mechanism - but probably just catching ExecutionException and retrying in while(true) loop will be fine (and some delays between retries).
https://github.com/scylladb/scylla-cdc-java/blob/avelanarius-changes/scylla-cdc-base/src/main/java/com/scylladb/cdc/model/master/Master.java
In
run()method, if thefetchGenerationMetadata()orgetGenerationId()fails, it crashes the entire Master and it doesn't try to retry.There should be some retry mechanism - but probably just catching
ExecutionExceptionand retrying inwhile(true)loop will be fine (and some delays between retries).