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:
Does this function work with current versions of Pig/Kafka? Also, are there plans to integrate this to Piggybank under the latest trunk Pig?
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.