pig icon indicating copy to clipboard operation
pig copied to clipboard

PIG-4472: KafkaStorage ready to update

Open Marvalero opened this issue 10 years ago • 2 comments

Here is a KafkaStorage function that export data from pig to Kafka in JSON format. I have used the libreries from http://mvnrepository.com: <groupId>org.apache.kafka</groupId> <artifactId>kafka_2.10</artifactId> 0.8.2.0

org.json json 20140107

Marvalero avatar Mar 20 '15 18:03 Marvalero

Does this function work with current versions of Pig/Kafka? Also, are there plans to integrate this to Piggybank under the latest trunk Pig?

maparco avatar Jan 14 '16 15:01 maparco

Please file a jira in https://issues.apache.org/jira/browse/PIG and upload a patch there. We do not accept git pull requests. Refer to https://cwiki.apache.org/confluence/display/PIG/HowToContribute#HowToContribute-Contributingyourwork for more details on the steps involved in contributing.

r0hini avatar Apr 27 '16 22:04 r0hini