[ https://issues.apache.org/jira/browse/BEAM-3611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Raghu Angadi reassigned BEAM-3611: ---------------------------------- Assignee: Raghu Angadi (was: Reuven Lax) > 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: Raghu Angadi > Priority: Minor > 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)