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

Reply via email to