Pushing data to Kafka via Pig

Hi all! When I run a pig script I get: java.lang.InstantiationError: org.apache.avro.io.BinaryEncoder at org.apache.hadoop.mapred.LocalJobRunner$Job.runTasks(LocalJobRunner.java:462) at org.apache.hadoop.mapred.LocalJobRunner$Job.run(LocalJobRunner.java:522) Caused by: java.lang.InstantiationErro

[jira] [Commented] (KAFKA-2368) Add Copycat standalone CLI

[ https://issues.apache.org/jira/browse/KAFKA-2368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14909909#comment-14909909 ] Gwen Shapira commented on KAFKA-2368: - While closing JIRA without doing any work is a

[jira] [Commented] (KAFKA-1215) Rack-Aware replica assignment option

[ https://issues.apache.org/jira/browse/KAFKA-1215?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14909911#comment-14909911 ] Allen Wang commented on KAFKA-1215: --- Started the work on KIP: https://cwiki.apache.org/

[jira] [Commented] (KAFKA-1804) Kafka network thread lacks top exception handler

[ https://issues.apache.org/jira/browse/KAFKA-1804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14909940#comment-14909940 ] Patrick J. McNerthney commented on KAFKA-1804: -- I ran into a similar issue wh

[jira] [Created] (KAFKA-2585) ConsoleConsumer should not hang infinitely upon exception

Dong Lin created KAFKA-2585: --- Summary: ConsoleConsumer should not hang infinitely upon exception Key: KAFKA-2585 URL: https://issues.apache.org/jira/browse/KAFKA-2585 Project: Kafka Issue Type: Bug

[GitHub] kafka pull request: KAFKA-2585; ConsoleConsumer should not hang in...

GitHub user lindong28 opened a pull request: https://github.com/apache/kafka/pull/247 KAFKA-2585; ConsoleConsumer should not hang infinitely upon exception You can merge this pull request into a Git repository by running: $ git pull https://github.com/lindong28/kafka KAFKA-258

[jira] [Commented] (KAFKA-2585) ConsoleConsumer should not hang infinitely upon exception

[ https://issues.apache.org/jira/browse/KAFKA-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14910055#comment-14910055 ] ASF GitHub Bot commented on KAFKA-2585: --- GitHub user lindong28 opened a pull request

[jira] [Updated] (KAFKA-2585) ConsoleConsumer should not hang infinitely upon exception

[ https://issues.apache.org/jira/browse/KAFKA-2585?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Dong Lin updated KAFKA-2585: Description: Due to imcompatibility beween Java 1.7 and Java 1.8, if Kafka ConsoleConsumer was compiled by

[jira] [Commented] (KAFKA-2368) Add Copycat standalone CLI

[ https://issues.apache.org/jira/browse/KAFKA-2368?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14910058#comment-14910058 ] Ewen Cheslack-Postava commented on KAFKA-2368: -- Marking this as part of the o

[jira] [Resolved] (KAFKA-2368) Add Copycat standalone CLI

[ https://issues.apache.org/jira/browse/KAFKA-2368?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava resolved KAFKA-2368. -- Resolution: Fixed > Add Copycat standalone CLI > -- > >

[jira] [Comment Edited] (KAFKA-1804) Kafka network thread lacks top exception handler

[ https://issues.apache.org/jira/browse/KAFKA-1804?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14909940#comment-14909940 ] Patrick J. McNerthney edited comment on KAFKA-1804 at 9/28/15 6:33 AM: -

[GitHub] kafka pull request: HOTFIX: Checkstye fixes follow up for KAKFA-25...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/248 HOTFIX: Checkstye fixes follow up for KAKFA-2531. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ewencp/kafka hotfix-kafka-2531-checkstyle Alter

[GitHub] kafka pull request: KAFKA-2482: Allow sink tasks to get their curr...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/249 KAFKA-2482: Allow sink tasks to get their current assignment, as well as pause and resume topic partitions. You can merge this pull request into a Git repository by running: $ git pull https://

[jira] [Commented] (KAFKA-2482) Allow copycat sink tasks to pause/resume consumption of specific topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-2482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14910100#comment-14910100 ] ASF GitHub Bot commented on KAFKA-2482: --- GitHub user ewencp opened a pull request:

[jira] [Updated] (KAFKA-2482) Allow copycat sink tasks to pause/resume consumption of specific topic partitions

[ https://issues.apache.org/jira/browse/KAFKA-2482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2482: - Reviewer: Gwen Shapira Status: Patch Available (was: Open) > Allow copycat

[GitHub] kafka pull request: KAFKA-2474: Add caching of JSON schema convers...

GitHub user ewencp opened a pull request: https://github.com/apache/kafka/pull/250 KAFKA-2474: Add caching of JSON schema conversions to JsonConverter. You can merge this pull request into a Git repository by running: $ git pull https://github.com/ewencp/kafka kafka-2474-cach

[jira] [Commented] (KAFKA-2474) Add caching for converted Copycat schemas in JSONConverter

[ https://issues.apache.org/jira/browse/KAFKA-2474?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14910109#comment-14910109 ] ASF GitHub Bot commented on KAFKA-2474: --- GitHub user ewencp opened a pull request:

[jira] [Updated] (KAFKA-2474) Add caching for converted Copycat schemas in JSONConverter

[ https://issues.apache.org/jira/browse/KAFKA-2474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ewen Cheslack-Postava updated KAFKA-2474: - Reviewer: Gwen Shapira Status: Patch Available (was: Open) > Add caching fo