[jira] [Created] (KAFKA-1006) Mirror maker loses messages of a new topic

2013-08-09 Thread Swapnil Ghike (JIRA)
Swapnil Ghike created KAFKA-1006: Summary: Mirror maker loses messages of a new topic Key: KAFKA-1006 URL: https://issues.apache.org/jira/browse/KAFKA-1006 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

2013-08-09 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13734903#comment-13734903 ] Jun Rao commented on KAFKA-992: --- Thanks for the patch. It doesn't seem to apply for me. Do

[jira] [Commented] (KAFKA-347) change number of partitions of a topic online

2013-08-09 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-347?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13734908#comment-13734908 ] Jun Rao commented on KAFKA-347: --- You just need to run bin/kafka-add-partitions.sh. We will

[jira] [Created] (KAFKA-1007) Document new tools before 0.8 release

2013-08-09 Thread Sriram Subramanian (JIRA)
Sriram Subramanian created KAFKA-1007: - Summary: Document new tools before 0.8 release Key: KAFKA-1007 URL: https://issues.apache.org/jira/browse/KAFKA-1007 Project: Kafka Issue Type:

Re: Kafka/Hadoop consumers and producers

2013-08-09 Thread Andrew Psaltis
Dibyendu, According to the pull request: https://github.com/linkedin/camus/pull/15 it was merged into the camus-kafka-0.8 branch. I have not checked if the code was subsequently removed, however, two at least one the important files from this patch

[jira] [Commented] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

2013-08-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13734994#comment-13734994 ] Guozhang Wang commented on KAFKA-992: - Thanks for the comments Jun. I think the

[jira] [Commented] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

2013-08-09 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13734999#comment-13734999 ] Neha Narkhede commented on KAFKA-992: - I agree with Guozhang that the logic to ensure

[jira] [Commented] (KAFKA-990) Fix ReassignPartitionCommand and improve usability

2013-08-09 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13735120#comment-13735120 ] Joel Koshy commented on KAFKA-990: -- Can you elaborate on the change to shutdownBroker in

Re: Kafka/Hadoop consumers and producers

2013-08-09 Thread Ken Goodhope
I just checked and that patch is in .8 branch. Thanks for working on back porting it Andrew. We'd be happy to commit that work to master. As for the kafka contrib project vs Camus, they are similar but not quite identical. Camus is intended to be a high throughput ETL for bulk ingestion of

[jira] [Updated] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

2013-08-09 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Guozhang Wang updated KAFKA-992: Attachment: KAFKA-992.v8.patch Incremental patch uploaded. Fixed a small issue that Json.parse will

[jira] [Commented] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

2013-08-09 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13735437#comment-13735437 ] Neha Narkhede commented on KAFKA-992: - +1 on v8. Good catch! Double

[jira] [Closed] (KAFKA-992) Double Check on Broker Registration to Avoid False NodeExist Exception

2013-08-09 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-992?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-992. --- Double Check on Broker Registration to Avoid False NodeExist Exception

[jira] [Commented] (KAFKA-990) Fix ReassignPartitionCommand and improve usability

2013-08-09 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-990?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=13735653#comment-13735653 ] Joel Koshy commented on KAFKA-990: -- Looks like I might have looked at the wrong patch.

Re: Kafka/Hadoop consumers and producers

2013-08-09 Thread dibyendu . bhattacharya
Hi Ken, I am also working on making the Camus fit for Non Avro message for our requirement. I see you mentioned about this patch (https://github.com/linkedin/camus/commit/87917a2aea46da9d21c8f67129f6463af52f7aa8) which supports custom data writer for Camus. But this patch is not pulled into