[
https://issues.apache.org/jira/browse/PIG-4472?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14371871#comment-14371871
]
ASF GitHub Bot commented on PIG-4472:
-------------------------------------
GitHub user Marvalero opened a pull request:
https://github.com/apache/pig/pull/17
PIG-4472: KafkaStorage ready to update
Here is a KafkaStorage function that export data from pig to Kafka in JSON
format. I have used the libreries from http://mvnrepository.com:
<dependency>
<groupId>org.apache.kafka</groupId>
<artifactId>kafka_2.10</artifactId>
<version>0.8.2.0</version>
</dependency>
<dependency>
<groupId>org.json</groupId>
<artifactId>json</artifactId>
<version>20140107</version>
</dependency>
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/Marvalero/pig kafka-storage
Alternatively you can review and apply these changes as the patch at:
https://github.com/apache/pig/pull/17.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 #17
----
commit 4f43e9be3d3986d8840b5134baf28158ac4bf6f7
Author: Marvalero <[email protected]>
Date: 2015-03-20T18:43:50Z
Adding KafkaStorage.java to Piggybank
commit 980867ec2cc01c5e2506a7ab1cdb8de70163d26d
Author: Marvalero <[email protected]>
Date: 2015-03-20T18:51:12Z
PIG-4472: Changing KafkaStorage.java to Piggybank
----
> KafkaStorage
> ------------
>
> Key: PIG-4472
> URL: https://issues.apache.org/jira/browse/PIG-4472
> Project: Pig
> Issue Type: Task
> Components: piggybank
> Environment: System with Pig and Hadoop that wants to send the output
> to Kafka
> Reporter: María Valero Campaña
> Assignee: María Valero Campaña
> Original Estimate: 72h
> Remaining Estimate: 72h
>
> New Pig Storage that send the output to Kafka
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
