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)