[jira] [Commented] (BEAM-2852) Add support for Kafka as source/sink on Nexmark
[ https://issues.apache.org/jira/browse/BEAM-2852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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)
[jira] [Commented] (BEAM-2852) Add support for Kafka as source/sink on Nexmark
[ https://issues.apache.org/jira/browse/BEAM-2852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16269703#comment-16269703 ] ASF GitHub Bot commented on BEAM-2852: -- aaltay commented on issue #3937: [BEAM-2852] Nexmark Kafka source sink URL: https://github.com/apache/beam/pull/3937#issuecomment-347699198 @vectorijk any updates? This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org > 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 > -- This message was sent by Atlassian JIRA (v6.4.14#64029)
[jira] [Commented] (BEAM-2852) Add support for Kafka as source/sink on Nexmark
[ https://issues.apache.org/jira/browse/BEAM-2852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16190423#comment-16190423 ] ASF GitHub Bot commented on BEAM-2852: -- GitHub user vectorijk opened a pull request: https://github.com/apache/beam/pull/3937 [BEAM-2852] Nexmark Kafka source sink Add support for Kafka as source/sink on Nexmark You can merge this pull request into a Git repository by running: $ git pull https://github.com/vectorijk/beam BEAM-2852-nexmark-kafka-source-sink Alternatively you can review and apply these changes as the patch at: https://github.com/apache/beam/pull/3937.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #3937 commit 46e380c162c32f55b74e2ed383978e4043fcf055 Author: Kai JiangDate: 2017-10-03T17:57:31Z sinkToKafka works still experiment sourceFromKafka commit 18128d29bb25db4a4381509fd19a1df5652cb395 Author: Kai Jiang Date: 2017-10-03T21:21:58Z source event from kafka commit d603dcdf1c4ad6e696eb0fec60e2d6fd31322234 Author: Kai Jiang Date: 2017-10-03T21:38:02Z clean code > 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 >Priority: Minor > Labels: newbie, starter > -- This message was sent by Atlassian JIRA (v6.4.14#64029)