Re: Review Request 21663: Patch for KAFKA-1456

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21663/#review43694 --- Reviewd code, applied patched and ran test cases. Looks good so far

Re: Review Request 21744: Patch for KAFKA-1446

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21744/#review43679 --- Ship it! Ship It! - Joel Koshy On May 21, 2014, 3:51 p.m., Sriha

[jira] [Commented] (KAFKA-1446) Consumer metrics for rebalance

[ https://issues.apache.org/jira/browse/KAFKA-1446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14005424#comment-14005424 ] Neha Narkhede commented on KAFKA-1446: -- The latest patch looks good to me. [~junrao],

Re: Review Request 21744: Patch for KAFKA-1446

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21744/#review43678 --- Ship it! Ship It! - Neha Narkhede On May 21, 2014, 3:51 p.m., Sr

[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14005249#comment-14005249 ] Jay Kreps commented on KAFKA-1316: -- Neha, yeah I'll post something as I get it in shape.

[jira] [Updated] (KAFKA-1462) Add new request and response formats for the new consumer and coordinator communication

[ https://issues.apache.org/jira/browse/KAFKA-1462?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1462: - Assignee: Jun Rao > Add new request and response formats for the new consumer and coordinator >

[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14005179#comment-14005179 ] Jun Rao commented on KAFKA-1316: Is ready() blocking? If not, does the user have to keep c

[jira] [Comment Edited] (KAFKA-1464) Add a throttling option to the Kafka replication tool

[ https://issues.apache.org/jira/browse/KAFKA-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14005052#comment-14005052 ] Jon Bringhurst edited comment on KAFKA-1464 at 5/21/14 6:35 PM:

[jira] [Commented] (KAFKA-1316) Refactor Sender

[ https://issues.apache.org/jira/browse/KAFKA-1316?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14005066#comment-14005066 ] Neha Narkhede commented on KAFKA-1316: -- [~jkreps] Thanks for writing this up. Thought

[jira] [Comment Edited] (KAFKA-1464) Add a throttling option to the Kafka replication tool

[ https://issues.apache.org/jira/browse/KAFKA-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14005052#comment-14005052 ] Jon Bringhurst edited comment on KAFKA-1464 at 5/21/14 6:34 PM:

[jira] [Comment Edited] (KAFKA-1464) Add a throttling option to the Kafka replication tool

[ https://issues.apache.org/jira/browse/KAFKA-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14005052#comment-14005052 ] Jon Bringhurst edited comment on KAFKA-1464 at 5/21/14 6:33 PM:

[jira] [Commented] (KAFKA-1464) Add a throttling option to the Kafka replication tool

[ https://issues.apache.org/jira/browse/KAFKA-1464?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14005052#comment-14005052 ] Jon Bringhurst commented on KAFKA-1464: --- Although this would be nice to have, someth

[jira] [Closed] (KAFKA-1298) Controlled shutdown tool doesn't seem to work out of the box

[ https://issues.apache.org/jira/browse/KAFKA-1298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede closed KAFKA-1298. > Controlled shutdown tool doesn't seem to work out of the box > --

[jira] [Updated] (KAFKA-1298) Controlled shutdown tool doesn't seem to work out of the box

[ https://issues.apache.org/jira/browse/KAFKA-1298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede updated KAFKA-1298: - Assignee: Sriharsha Chintalapani > Controlled shutdown tool doesn't seem to work out of the box >

[jira] [Resolved] (KAFKA-1298) Controlled shutdown tool doesn't seem to work out of the box

[ https://issues.apache.org/jira/browse/KAFKA-1298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Neha Narkhede resolved KAFKA-1298. -- Resolution: Fixed Thanks for the patches, pushed to trunk > Controlled shutdown tool doesn't s

Re: Review Request 21676: Patch for KAFKA-1298

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21676/#review43642 --- Ship it! Ship It! - Neha Narkhede On May 20, 2014, 1:50 a.m., Sr

[jira] [Created] (KAFKA-1464) Add a throttling option to the Kafka replication tool

Marcos Juarez created KAFKA-1464: Summary: Add a throttling option to the Kafka replication tool Key: KAFKA-1464 URL: https://issues.apache.org/jira/browse/KAFKA-1464 Project: Kafka Issue Typ

[jira] [Resolved] (KAFKA-893) Unable to access kafka via Tomcat

[ https://issues.apache.org/jira/browse/KAFKA-893?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] arathi m resolved KAFKA-893. Resolution: Fixed Using Kafka dependency in my maven pom.xml org.apache.kafka kafka_2.10

[jira] [Commented] (KAFKA-1446) Consumer metrics for rebalance

[ https://issues.apache.org/jira/browse/KAFKA-1446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14004806#comment-14004806 ] Sriharsha Chintalapani commented on KAFKA-1446: --- Updated reviewboard https:/

[jira] [Updated] (KAFKA-1446) Consumer metrics for rebalance

[ https://issues.apache.org/jira/browse/KAFKA-1446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1446: -- Attachment: KAFKA-1446_2014-05-21_08:51:52.patch > Consumer metrics for rebalan

[jira] [Commented] (KAFKA-1463) producer fails with scala.tuple error

[ https://issues.apache.org/jira/browse/KAFKA-1463?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14004810#comment-14004810 ] Jun Rao commented on KAFKA-1463: Could you make sure the scala jar at runtime matches that

Re: Review Request 21744: Patch for KAFKA-1446

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21744/ --- (Updated May 21, 2014, 3:51 p.m.) Review request for kafka. Bugs: KAFKA-1446

Re: Review Request 21744: Patch for KAFKA-1446

> On May 21, 2014, 1:26 a.m., Joel Koshy wrote: > > core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala, line > > 109 > > > > > > Can just call these -RebalancesPerMin and -RebalanceTime Thanks for th

[jira] [Updated] (KAFKA-1446) Consumer metrics for rebalance

[ https://issues.apache.org/jira/browse/KAFKA-1446?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sriharsha Chintalapani updated KAFKA-1446: -- Attachment: KAFKA-1446_2014-05-21_08:19:49.patch > Consumer metrics for rebalan

[jira] [Commented] (KAFKA-1446) Consumer metrics for rebalance

[ https://issues.apache.org/jira/browse/KAFKA-1446?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14004757#comment-14004757 ] Sriharsha Chintalapani commented on KAFKA-1446: --- Updated reviewboard https:/

Re: Review Request 21744: Patch for KAFKA-1446

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21744/ --- (Updated May 21, 2014, 3:19 p.m.) Review request for kafka. Bugs: KAFKA-1446

Re: Review Request 21744: Patch for KAFKA-1446

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/21744/#review43616 --- core/src/main/scala/kafka/consumer/ZookeeperConsumerConnector.scala

Re: Make kafka storage engine pluggable and provide a HDFS plugin?

Hi Hangjun I've explored deploying kafka on yarn and current YARN does not support long running services with locality constraints. Deploying kafka producers / consumers (not brokers) is supported in the apache incubator samza project. Background on YARN limitations can be found here: YARN-371,

[jira] [Created] (KAFKA-1463) producer fails with scala.tuple error

Joe created KAFKA-1463: -- Summary: producer fails with scala.tuple error Key: KAFKA-1463 URL: https://issues.apache.org/jira/browse/KAFKA-1463 Project: Kafka Issue Type: Bug Components: produce