Details
-
Improvement
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
None
-
None
Description
KafkaIO.java has grown too big and includes both source and sink implementation. Better to move these to own files.
Attachments
Issue Links
- links to