Details
-
Improvement
-
Status: Patch Available
-
Major
-
Resolution: Unresolved
-
None
-
None
-
None
Description
When implementing MM2 EOS feature, existing functions from `MirrorSourceConnector` and `MirrorSourceTask` can be reused for `MirrorSinkConnector` and `MirrorSinkTask`.
To minimize the maintenance cost in the long-term and maximum the code reusability, it worths to extract common functions out of current `MirrorSourceConnector` and `MirrorSourceTask`.
Attachments
Issue Links
- blocks
-
KAFKA-10339 MirrorMaker2 Exactly-once Semantics
- Resolved