[jira] [Issue Comment Edited] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Joe Stein (Issue Comment Edited) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221523#comment-13221523 ] Joe Stein edited comment on KAFKA-240 at 3/3/12 5:47 AM: - 9) done 1

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221523#comment-13221523 ] Joe Stein commented on KAFKA-240: - 9) done 10) done change member vars to camel case for c

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221495#comment-13221495 ] Joe Stein commented on KAFKA-240: - Thanks Jun, I get the issue now. Right, so after I read

[jira] [Updated] (KAFKA-292) broker deletes all file segments when cleaning up an empty log segment

2012-03-02 Thread Jun Rao (Updated) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-292: -- Attachment: kafka-292.patch > broker deletes all file segments when cleaning up an empty log segment > -

[jira] [Updated] (KAFKA-292) broker deletes all file segments when cleaning up an empty log segment

2012-03-02 Thread Jun Rao (Updated) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-292: -- Status: Patch Available (was: Open) patch attached. > broker deletes all file segments when cl

[jira] [Created] (KAFKA-292) broker deletes all file segments when cleaning up an empty log segment

2012-03-02 Thread Jun Rao (Created) (JIRA)
broker deletes all file segments when cleaning up an empty log segment -- Key: KAFKA-292 URL: https://issues.apache.org/jira/browse/KAFKA-292 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Jun Rao (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221452#comment-13221452 ] Jun Rao commented on KAFKA-240: --- Joe, When the client creates a ProduceRequest, we don't nee

[jira] [Commented] (KAFKA-291) Add builder to create configs for consumer and broker

2012-03-02 Thread John Wang (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-291?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221364#comment-13221364 ] John Wang commented on KAFKA-291: - examples (in java): Producer: instead of: Propertie

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221353#comment-13221353 ] Joe Stein commented on KAFKA-240: - It is written to the buffer though it is not passed in w

Re: Kafka is live in prod @ 100%

2012-03-02 Thread Neha Narkhede
Thai, Do you really need to specify the number of partitions differently for so many topics ? I wonder if setting the right default for num.partitions works instead ? Thanks, Neha On Sun, Feb 19, 2012 at 6:47 PM, Bao Thai Ngo wrote: > Hi, > > I like the idea Taylor suggested. This will definite

[jira] [Commented] (KAFKA-279) kafka-console-producer does not take in customized values of --batch-size or --timeout

2012-03-02 Thread Neha Narkhede (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-279?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221349#comment-13221349 ] Neha Narkhede commented on KAFKA-279: - Milind, does the attached patch fix your problem

[jira] [Updated] (KAFKA-269) ./system_test/producer_perf/bin/run-test.sh without --async flag does not run

2012-03-02 Thread Neha Narkhede (Updated) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-269?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-269: Labels: newbie performance (was: performance) > ./system_test/producer_perf/bin/run-test.sh wi

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Jun Rao (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221318#comment-13221318 ] Jun Rao commented on KAFKA-240: --- Yes, however, that information is not passed into ProduceReq

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221290#comment-13221290 ] Joe Stein commented on KAFKA-240: - Hi Jun, on #9 def readFrom(buffer: ByteBuffer): Prod

[jira] [Updated] (KAFKA-291) Add builder to create configs for consumer and broker

2012-03-02 Thread John Wang (Updated) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-291?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] John Wang updated KAFKA-291: Attachment: builderPatch.diff > Add builder to create configs for consumer and broker >

[jira] [Created] (KAFKA-291) Add builder to create configs for consumer and broker

2012-03-02 Thread John Wang (Created) (JIRA)
Add builder to create configs for consumer and broker - Key: KAFKA-291 URL: https://issues.apache.org/jira/browse/KAFKA-291 Project: Kafka Issue Type: Improvement Components: core

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Jun Rao (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221183#comment-13221183 ] Jun Rao commented on KAFKA-240: --- Joe, kafka-239 has been committed to the 0.8 branch. You a

[jira] [Updated] (KAFKA-239) Wire existing producer and consumer to use the new ZK data structure

2012-03-02 Thread Jun Rao (Updated) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-239?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-239: -- Resolution: Fixed Fix Version/s: 0.8 Status: Resolved (was: Patch Available) > Wire exist

[jira] [Commented] (KAFKA-240) implement new producer and consumer request format

2012-03-02 Thread Joe Stein (Commented) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-240?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13221162#comment-13221162 ] Joe Stein commented on KAFKA-240: - ok, sounds good. I will commit the changes with these l

[jira] [Updated] (KAFKA-50) kafka intra-cluster replication support

2012-03-02 Thread Jun Rao (Updated) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-50?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-50: - Attachment: kafka_replication_highlevel_design.docx > kafka intra-cluster replication support > ---

[jira] [Updated] (KAFKA-50) kafka intra-cluster replication support

2012-03-02 Thread Jun Rao (Updated) (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-50?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-50: - Attachment: kafka_replication_detailed_design_v2.docx Attach the word doc of the design. > kafka i