[jira] [Created] (BEAM-3611) Split KafkaIO.java into smaller files

[Raghu Angadi (JIRA)]

Raghu Angadi created BEAM-3611:
----------------------------------

             Summary: Split KafkaIO.java into smaller files
                 Key: BEAM-3611
                 URL: https://issues.apache.org/jira/browse/BEAM-3611
             Project: Beam
          Issue Type: Improvement
          Components: sdk-java-extensions
            Reporter: Raghu Angadi
            Assignee: Reuven Lax
             Fix For: 2.4.0


KafkaIO.java has grown too big and includes both source and sink 
implementation. Better to move these to own files. 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)