[ https://issues.apache.org/jira/browse/BEAM-2852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16427272#comment-16427272 ]
Alexey Romanenko commented on BEAM-2852: ---------------------------------------- I'd take this one since there was not update for a while. I closed old PR and created new one with keeping of all authorship of [~vectorijk] of original commits (only squashed them into one). > Add support for Kafka as source/sink on Nexmark > ----------------------------------------------- > > Key: BEAM-2852 > URL: https://issues.apache.org/jira/browse/BEAM-2852 > Project: Beam > Issue Type: Improvement > Components: testing > Reporter: Ismaël Mejía > Assignee: Kai Jiang > Priority: Minor > Labels: newbie, nexmark, starter > Time Spent: 2h 50m > Remaining Estimate: 0h > -- This message was sent by Atlassian JIRA (v7.6.3#76005)