-
Type: Improvement
-
Resolution: Unresolved
-
Priority: Minor - P4
-
None
-
Affects Version/s: None
-
Component/s: Sink
-
None
DeleteOneBusinessKeyStrategy, ReplaceOneBusinessKeyStrategy (maybe other places in the codebase) need to differentiate partial IdStrategy. Currently this is done by using the following code:
isPartialId = idStrategy instanceof PartialKeyStrategy || idStrategy instanceof PartialValueStrategy;
This code relies on the preexisting knowledge of all partial IdStrategy implementations. This means that if a new partial implementation appears, the code mentioned above will have to be updated in multiple places. The problem with this approach is that the author of the new partial implementation has no way of knowing that there are places in the codebase that must be updated.
We could add a mechanism of differentiating partial IdStrategy by using, for example, one of the following approaches:
- A new default method IdStrategy.isPartial returning false. This is the preferable approach.
- A new marker interface IdStrategy.Partial. This approach should only be considered if implementing the first approach encounters difficulties not apparent at the point of creating this ticket.
Fo more details, please see the original review discussion.
- split from
-
KAFKA-168 Add a DeleteOneBusinessKeyStrategy
- Closed