Details
-
Improvement
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
3.0.0
-
None
Description
There's a comment in KafkaContinuousSinkSuite which is most likely explaining TODO:
/** * This is a temporary port of KafkaSinkSuite, since we do not yet have a V2 memory stream. * Once we have one, this will be changed to a specialization of KafkaSinkSuite and we won't have * to duplicate all the code. */
Given latest master branch has V2 memory stream now, it is a good time to deduplicate two suites into one, via having base class and let these suites override necessary things.
Attachments
Issue Links
- links to