[jira] [Commented] (BEAM-2852) Add support for Kafka as source/sink on Nexmark

[Alexey Romanenko (JIRA)]

[ 
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

[ASF GitHub Bot (JIRA)]

[ 
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

[ASF GitHub Bot (JIRA)]

[ 
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 Jiang 
Date:   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)