Flume-NG Kafka Channel

I started hacking on a Kafka Channel for Flume-NG. It has a Java Consumer and Java Producer based on the java example code that works with the PUT and TAKE methods on the Channel Interface. Any thoughts? Kafka makes a really powerful addition to the existing channel options. -Jonathan -- ** *

[jira] [Updated] (KAFKA-779) Standardize Zk data structures for Re-assign partitions and Preferred replication election

[ https://issues.apache.org/jira/browse/KAFKA-779?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-779: Labels: kafka-0.8 p2 (was: p2) > Standardize Zk data structures for Re-assign partitions and Pr

[jira] [Created] (KAFKA-779) Standardize Zk data structures for Re-assign partitions and Preferred replication election

Swapnil Ghike created KAFKA-779: --- Summary: Standardize Zk data structures for Re-assign partitions and Preferred replication election Key: KAFKA-779 URL: https://issues.apache.org/jira/browse/KAFKA-779

[jira] [Updated] (KAFKA-513) Add state change log to Kafka brokers

[ https://issues.apache.org/jira/browse/KAFKA-513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Swapnil Ghike updated KAFKA-513: Attachment: kafka-513-v4.patch Uploading patch v4. The comments on the merge tool are written above.

[jira] [Updated] (KAFKA-777) Add system tests for important tools

[ https://issues.apache.org/jira/browse/KAFKA-777?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-777: Labels: kafka-0.8 p2 replication-testing (was: kafka-0.8 p1 replication-testing) > Add system

[jira] [Updated] (KAFKA-759) Commit/FetchOffset APIs should not return versionId

[ https://issues.apache.org/jira/browse/KAFKA-759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-759: Resolution: Fixed Fix Version/s: (was: 0.8) 0.8.1 Status: Re

[jira] [Closed] (KAFKA-759) Commit/FetchOffset APIs should not return versionId

[ https://issues.apache.org/jira/browse/KAFKA-759?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-759. --- > Commit/FetchOffset APIs should not return versionId > --

[jira] [Commented] (KAFKA-759) Commit/FetchOffset APIs should not return versionId

[ https://issues.apache.org/jira/browse/KAFKA-759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13590973#comment-13590973 ] Neha Narkhede commented on KAFKA-759: - +1, looks good > Commit/FetchOf

[jira] [Updated] (KAFKA-772) System Test Transient Failure on testcase_0122

[ https://issues.apache.org/jira/browse/KAFKA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-772: Attachment: testcase_0125.tar.gz > System Test Transient Failure on testcase_0122 >

[jira] [Updated] (KAFKA-772) System Test Transient Failure on testcase_0122

[ https://issues.apache.org/jira/browse/KAFKA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-772: Attachment: (was: testcase_0125.tar.gz) > System Test Transient Failure on testcase_0122 > -

[jira] [Commented] (KAFKA-772) System Test Transient Failure on testcase_0122

[ https://issues.apache.org/jira/browse/KAFKA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13590771#comment-13590771 ] John Fung commented on KAFKA-772: - There is a similar failure in testcase_0125 yesterday in

[jira] [Updated] (KAFKA-772) System Test Transient Failure on testcase_0122

[ https://issues.apache.org/jira/browse/KAFKA-772?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Fung updated KAFKA-772: Attachment: testcase_0125.tar.gz > System Test Transient Failure on testcase_0122 >