[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

2014-07-30 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14079219#comment-14079219 ] nicu marasoiu commented on KAFKA-1510: -- [~jkreps] Hi, can you please help me with

[jira] [Resolved] (KAFKA-1451) Broker stuck due to leader election race

2014-07-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1451?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao resolved KAFKA-1451. Resolution: Fixed Fix Version/s: 0.8.2 Thanks for the latest patch. +1 and committed to trunk.

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

2014-07-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14079373#comment-14079373 ] Jun Rao commented on KAFKA-1555: Instead of introducing a new property min.isr.required, I

[jira] [Commented] (KAFKA-1507) Using GetOffsetShell against non-existent topic creates the topic unintentionally

2014-07-30 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14079439#comment-14079439 ] Sriharsha Chintalapani commented on KAFKA-1507: --- [~junrao] [~jkreps] Thanks

[jira] [Commented] (KAFKA-1507) Using GetOffsetShell against non-existent topic creates the topic unintentionally

2014-07-30 Thread Jay Kreps (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1507?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14079483#comment-14079483 ] Jay Kreps commented on KAFKA-1507: -- Maybe the best plan would be to retain the option we

[jira] [Created] (KAFKA-1563) High packet rate between brokers in kafka cluster.

2014-07-30 Thread Fedor Korotkiy (JIRA)
Fedor Korotkiy created KAFKA-1563: - Summary: High packet rate between brokers in kafka cluster. Key: KAFKA-1563 URL: https://issues.apache.org/jira/browse/KAFKA-1563 Project: Kafka Issue

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

2014-07-30 Thread saurabh agarwal (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14079494#comment-14079494 ] saurabh agarwal commented on KAFKA-1555: Excellent. Thanks. It works for us. We

[jira] [Assigned] (KAFKA-1562) kafka-topics.sh alter add partitions resets cleanup.policy

2014-07-30 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani reassigned KAFKA-1562: - Assignee: Sriharsha Chintalapani kafka-topics.sh alter add partitions

Re: Review Request 24006: Patch for KAFKA-1420

2014-07-30 Thread Jonathan Natkins
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24006/ --- (Updated July 30, 2014, 6:18 p.m.) Review request for kafka. Bugs:

[jira] [Updated] (KAFKA-1420) Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with TestUtils.createTopic in unit tests

2014-07-30 Thread Jonathan Natkins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Natkins updated KAFKA-1420: Attachment: KAFKA-1420_2014-07-30_11:18:26.patch Replace

[jira] [Commented] (KAFKA-1420) Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with TestUtils.createTopic in unit tests

2014-07-30 Thread Jonathan Natkins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14079690#comment-14079690 ] Jonathan Natkins commented on KAFKA-1420: - Updated reviewboard

Re: Review Request 24006: Patch for KAFKA-1420

2014-07-30 Thread Jonathan Natkins
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24006/ --- (Updated July 30, 2014, 6:24 p.m.) Review request for kafka. Bugs:

[jira] [Updated] (KAFKA-1420) Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with TestUtils.createTopic in unit tests

2014-07-30 Thread Jonathan Natkins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Natkins updated KAFKA-1420: Attachment: KAFKA-1420_2014-07-30_11:24:55.patch Replace

[jira] [Commented] (KAFKA-1420) Replace AdminUtils.createOrUpdateTopicPartitionAssignmentPathInZK with TestUtils.createTopic in unit tests

2014-07-30 Thread Jonathan Natkins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1420?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14079699#comment-14079699 ] Jonathan Natkins commented on KAFKA-1420: - Updated reviewboard

Re: Review Request 24006: Patch for KAFKA-1420

2014-07-30 Thread Jonathan Natkins
On July 30, 2014, 12:22 a.m., Guozhang Wang wrote: core/src/test/scala/unit/kafka/admin/AdminTest.scala, line 314 https://reviews.apache.org/r/24006/diff/1/?file=643839#file643839line314 Is there a specific reason we want to use 10 seconds instead of default 5 seconds? Sorry,

[jira] [Updated] (KAFKA-1333) Add consumer co-ordinator module to the server

2014-07-30 Thread Neha Narkhede (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1333?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1333: - Assignee: Guozhang Wang Add consumer co-ordinator module to the server

Re: Review Request 24006: Patch for KAFKA-1420

2014-07-30 Thread Jonathan Natkins
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24006/#review49139 --- core/src/test/scala/unit/kafka/admin/AdminTest.scala

Build failed in Jenkins: Kafka-trunk #237

2014-07-30 Thread Apache Jenkins Server
See https://builds.apache.org/job/Kafka-trunk/237/changes Changes: [junrao] kafka-1451; Broker stuck due to leader election race; patched by Manikumar Reddy; reviewed by Jun Rao -- [...truncated 780 lines...] kafka.server.KafkaConfigTest

[jira] [Commented] (KAFKA-1562) kafka-topics.sh alter add partitions resets cleanup.policy

2014-07-30 Thread Jonathan Natkins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14079846#comment-14079846 ] Jonathan Natkins commented on KAFKA-1562: - If it's alright, I was planning on

Review Request 24113: Patch for KAFKA-1562

2014-07-30 Thread Jonathan Natkins
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24113/ --- Review request for kafka. Bugs: KAFKA-1562

Re: Review Request 24113: Patch for KAFKA-1562

2014-07-30 Thread Jonathan Natkins
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24113/ --- (Updated July 30, 2014, 8:18 p.m.) Review request for kafka. Bugs:

Re: Review Request 24113: Patch for KAFKA-1562

2014-07-30 Thread Jonathan Natkins
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24113/ --- (Updated July 30, 2014, 8:18 p.m.) Review request for kafka. Bugs:

[jira] [Updated] (KAFKA-1562) kafka-topics.sh alter add partitions resets cleanup.policy

2014-07-30 Thread Jonathan Natkins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Natkins updated KAFKA-1562: Attachment: KAFKA-1562.patch kafka-topics.sh alter add partitions resets cleanup.policy

[jira] [Updated] (KAFKA-1562) kafka-topics.sh alter add partitions resets cleanup.policy

2014-07-30 Thread Jonathan Natkins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Natkins updated KAFKA-1562: Attachment: KAFKA-1562_2014-07-30_13:18:21.patch kafka-topics.sh alter add partitions

[jira] [Commented] (KAFKA-1562) kafka-topics.sh alter add partitions resets cleanup.policy

2014-07-30 Thread Jonathan Natkins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14079897#comment-14079897 ] Jonathan Natkins commented on KAFKA-1562: - Updated reviewboard

[jira] [Commented] (KAFKA-1562) kafka-topics.sh alter add partitions resets cleanup.policy

2014-07-30 Thread Jonathan Natkins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14079893#comment-14079893 ] Jonathan Natkins commented on KAFKA-1562: - Created reviewboard

[jira] [Updated] (KAFKA-1562) kafka-topics.sh alter add partitions resets cleanup.policy

2014-07-30 Thread Jonathan Natkins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Natkins updated KAFKA-1562: Status: Patch Available (was: Open) kafka-topics.sh alter add partitions resets

Re: Review Request 24113: Patch for KAFKA-1562

2014-07-30 Thread Sriharsha Chintalapani
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24113/#review49158 --- core/src/main/scala/kafka/admin/AdminUtils.scala

[jira] [Updated] (KAFKA-1562) kafka-topics.sh alter add partitions resets cleanup.policy

2014-07-30 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1562: -- Assignee: (was: Sriharsha Chintalapani) kafka-topics.sh alter add

Re: Review Request 24113: Patch for KAFKA-1562

2014-07-30 Thread Jonathan Natkins
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/24113/ --- (Updated July 30, 2014, 8:51 p.m.) Review request for kafka. Bugs:

[jira] [Updated] (KAFKA-1562) kafka-topics.sh alter add partitions resets cleanup.policy

2014-07-30 Thread Jonathan Natkins (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jonathan Natkins updated KAFKA-1562: Attachment: KAFKA-1562_2014-07-30_13:51:25.patch kafka-topics.sh alter add partitions

[jira] [Commented] (KAFKA-1510) Force offset commits when migrating consumer offsets from zookeeper to kafka

2014-07-30 Thread Joel Koshy (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14080164#comment-14080164 ] Joel Koshy commented on KAFKA-1510: --- [~nmarasoi] - sure thing. Will get back to you on

[jira] [Commented] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-07-30 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14080174#comment-14080174 ] Joe Stein commented on KAFKA-1477: -- [~jkreps] agreed, next week sounds good add

[jira] [Commented] (KAFKA-1555) provide strong consistency with reasonable availability

2014-07-30 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1555?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14080210#comment-14080210 ] Joe Stein commented on KAFKA-1555: -- +1 to introduce a new semantic when ack = -2. The

[jira] [Commented] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-07-30 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14080335#comment-14080335 ] Gwen Shapira commented on KAFKA-1477: - [~joestein] [~jkreps] So the next steps are

[jira] [Commented] (KAFKA-1477) add authentication layer and initial JKS x509 implementation for brokers, producers and consumer for network communication

2014-07-30 Thread Joe Stein (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14080355#comment-14080355 ] Joe Stein commented on KAFKA-1477: -- Hey [~gwenshap] take a look where we are so far