Re: Review Request 35231: Address Onur and Jason's comments

2015-06-30 Thread Onur Karaman
On June 18, 2015, 12:50 a.m., Jason Gustafson wrote: core/src/main/scala/kafka/coordinator/ConsumerCoordinator.scala, lines 229-236 https://reviews.apache.org/r/35231/diff/1/?file=980918#file980918line229 In manual group management, would we expect consumerId and generationId

Re: Review Request 36030: Patch for KAFKA-972

2015-06-30 Thread Ashish Singh
On June 30, 2015, 4:14 p.m., Jun Rao wrote: Thanks for the patch. A few comments below. 1. Could you add a unit test for this? 2. Also, we may have a similar issue when handling the failure of the broker. Currently, the logic in the controller is that the controller will only

[jira] [Commented] (KAFKA-972) MetadataRequest returns stale list of brokers

2015-06-30 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-972?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14609426#comment-14609426 ] Ashish K Singh commented on KAFKA-972: -- Updated reviewboard

[jira] [Updated] (KAFKA-972) MetadataRequest returns stale list of brokers

2015-06-30 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-972: - Status: Patch Available (was: In Progress) MetadataRequest returns stale list of brokers

Re: Review Request 36030: Patch for KAFKA-972

2015-06-30 Thread Ashish Singh
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/36030/ --- (Updated July 1, 2015, 1:42 a.m.) Review request for kafka. Bugs: KAFKA-972

[jira] [Updated] (KAFKA-972) MetadataRequest returns stale list of brokers

2015-06-30 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-972?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-972: - Attachment: KAFKA-972_2015-06-30_18:42:13.patch MetadataRequest returns stale list of brokers

Re: Review Request 33378: Patch for KAFKA-2136

2015-06-30 Thread Aditya Auradkar
On June 25, 2015, 10:55 p.m., Joel Koshy wrote: core/src/main/scala/kafka/server/AbstractFetcherThread.scala, line 40 https://reviews.apache.org/r/33378/diff/8/?file=981582#file981582line40 I think we should add throttle time metrics to the old producer and consumer as well. What

Re: Review Request 33378: Patch for KAFKA-2136

2015-06-30 Thread Aditya Auradkar
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33378/ --- (Updated July 1, 2015, 2:44 a.m.) Review request for kafka, Joel Koshy and Jun

[jira] [Commented] (KAFKA-2136) Client side protocol changes to return quota delays

2015-06-30 Thread Aditya A Auradkar (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14609476#comment-14609476 ] Aditya A Auradkar commented on KAFKA-2136: -- Updated reviewboard

Re: Review Request 33378: Patch for KAFKA-2136

2015-06-30 Thread Aditya Auradkar
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33378/ --- (Updated July 1, 2015, 2:44 a.m.) Review request for kafka, Joel Koshy and Jun

Re: Review Request 34766: Patch for KAFKA-2229

2015-06-30 Thread Andrii Biletskyi
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34766/ --- (Updated June 30, 2015, 1:59 p.m.) Review request for kafka. Bugs:

[jira] [Updated] (KAFKA-2229) Phase 1: Requests and KafkaApis

2015-06-30 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2229?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Andrii Biletskyi updated KAFKA-2229: Attachment: KAFKA-2229_2015-06-30_16:59:17.patch Phase 1: Requests and KafkaApis

[jira] [Commented] (KAFKA-2229) Phase 1: Requests and KafkaApis

2015-06-30 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608307#comment-14608307 ] Andrii Biletskyi commented on KAFKA-2229: - Updated reviewboard

[jira] [Commented] (KAFKA-2229) Phase 1: Requests and KafkaApis

2015-06-30 Thread Andrii Biletskyi (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2229?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608309#comment-14608309 ] Andrii Biletskyi commented on KAFKA-2229: - Rebased to include KAFKA-2195. Phase

Re: Review Request 36030: Patch for KAFKA-972

2015-06-30 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/36030/#review90005 --- Thanks for the patch. A couple more comments.

[jira] [Commented] (KAFKA-873) Consider replacing zkclient with curator (with zkclient-bridge)

2015-06-30 Thread Ross Black (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-873?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14609591#comment-14609591 ] Ross Black commented on KAFKA-873: -- A more general mechanism could also support KAFKA-1793

Re: Review Request 35231: Address Onur and Jason's comments

2015-06-30 Thread Guozhang Wang
On June 18, 2015, 12:50 a.m., Jason Gustafson wrote: core/src/main/scala/kafka/coordinator/ConsumerCoordinator.scala, lines 229-236 https://reviews.apache.org/r/35231/diff/1/?file=980918#file980918line229 In manual group management, would we expect consumerId and generationId

[jira] [Commented] (KAFKA-1690) new java producer needs ssl support as a client

2015-06-30 Thread Rajasekar Elango (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608572#comment-14608572 ] Rajasekar Elango commented on KAFKA-1690: - [~harsha_ch] Thanks for working on

Re: Review Request 33620: Patch for KAFKA-1690

2015-06-30 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33620/#review89677 --- Thanks for the patch. A few comments below. Also, we need to

[jira] [Commented] (KAFKA-1690) new java producer needs ssl support as a client

2015-06-30 Thread Sriharsha Chintalapani (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608583#comment-14608583 ] Sriharsha Chintalapani commented on KAFKA-1690: --- [~erajasekar] you can try

[jira] [Updated] (KAFKA-1367) Broker topic metadata not kept in sync with ZooKeeper

2015-06-30 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1367?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-1367: --- Status: In Progress (was: Patch Available) Broker topic metadata not kept in sync with ZooKeeper

Re: Review Request 33620: Patch for KAFKA-1690

2015-06-30 Thread Joel Koshy
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33620/#review89922 --- I have a few other comments which I can add later or discuss

Re: Review Request 35231: Address Onur and Jason's comments

2015-06-30 Thread Jason Gustafson
On June 18, 2015, 12:50 a.m., Jason Gustafson wrote: core/src/main/scala/kafka/coordinator/ConsumerCoordinator.scala, lines 229-236 https://reviews.apache.org/r/35231/diff/1/?file=980918#file980918line229 In manual group management, would we expect consumerId and generationId

[jira] [Updated] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

2015-06-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2168: --- Attachment: KAFKA-2168_2015-06-30_10:54:22.patch New consumer poll() can block other calls

[jira] [Commented] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

2015-06-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608743#comment-14608743 ] Jason Gustafson commented on KAFKA-2168: Updated reviewboard

Re: Review Request 34789: Patch for KAFKA-2168

2015-06-30 Thread Jason Gustafson
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34789/ --- (Updated June 30, 2015, 5:55 p.m.) Review request for kafka. Bugs:

Re: Review Request 33620: Patch for KAFKA-1690

2015-06-30 Thread Michael Herstine
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33620/#review89910 --- clients/src/main/java/org/apache/kafka/clients/ClientUtils.java

[jira] [Commented] (KAFKA-2168) New consumer poll() can block other calls like position(), commit(), and close() indefinitely

2015-06-30 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608753#comment-14608753 ] Jason Gustafson commented on KAFKA-2168: [~ewencp], there were some minor issues

Re: Review Request 33614: Patch for KAFKA-2132

2015-06-30 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33614/#review89919 --- Thanks for the patch. Just a few minor comments below.

[jira] [Commented] (KAFKA-2132) Move Log4J appender to a separate module

2015-06-30 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14608883#comment-14608883 ] Ashish K Singh commented on KAFKA-2132: --- Updated reviewboard

Re: Review Request 33614: Patch for KAFKA-2132

2015-06-30 Thread Ashish Singh
On June 30, 2015, 5:12 p.m., Jun Rao wrote: Thanks for the patch. Just a few minor comments below. Thanks Jun for the review. On June 30, 2015, 5:12 p.m., Jun Rao wrote: build.gradle, lines 389-391 https://reviews.apache.org/r/33614/diff/9/?file=991359#file991359line389 Could

Re: Review Request 33614: Patch for KAFKA-2132

2015-06-30 Thread Ashish Singh
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33614/ --- (Updated June 30, 2015, 7:07 p.m.) Review request for kafka. Bugs:

[jira] [Commented] (KAFKA-2304) Support enabling JMX in Kafka Vagrantfile

2015-06-30 Thread Ewen Cheslack-Postava (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14609046#comment-14609046 ] Ewen Cheslack-Postava commented on KAFKA-2304: -- Patch works and looks fine to

[jira] [Updated] (KAFKA-2304) Support enabling JMX in Kafka Vagrantfile

2015-06-30 Thread Stevo Slavic (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Stevo Slavic updated KAFKA-2304: Attachment: KAFKA-2304-JMX.patch Makes sense, changed. Attached updated [^KAFKA-2304-JMX.patch]

[jira] [Updated] (KAFKA-2132) Move Log4J appender to a separate module

2015-06-30 Thread Ashish K Singh (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2132?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh updated KAFKA-2132: -- Attachment: KAFKA-2132_2015-06-30_12:07:23.patch Move Log4J appender to a separate module

Re: Review Request 34494: Patch for KAFKA-2212

2015-06-30 Thread Tom Graves
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34494/#review89940 --- core/src/main/scala/kafka/admin/AclCommand.scala (line 48)

Re: Review Request 35231: Address Onur and Jason's comments

2015-06-30 Thread Onur Karaman
On June 18, 2015, 12:50 a.m., Jason Gustafson wrote: core/src/main/scala/kafka/coordinator/ConsumerCoordinator.scala, lines 229-236 https://reviews.apache.org/r/35231/diff/1/?file=980918#file980918line229 In manual group management, would we expect consumerId and generationId

Re: Review Request 34789: Patch for KAFKA-2168

2015-06-30 Thread Jason Gustafson
On June 30, 2015, 10:24 p.m., Guozhang Wang wrote: clients/src/main/java/org/apache/kafka/clients/consumer/KafkaConsumer.java, lines 933-937 https://reviews.apache.org/r/34789/diff/14/?file=996120#file996120line933 Wondering why we want to fetch for all assigned partitions if the

[jira] [Commented] (KAFKA-2078) Getting Selector [WARN] Error in I/O with host java.io.EOFException

2015-06-30 Thread Michael Sandrof (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2078?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14609220#comment-14609220 ] Michael Sandrof commented on KAFKA-2078: We are experiencing the same issue in

Re: Review Request 34789: Patch for KAFKA-2168

2015-06-30 Thread Guozhang Wang
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34789/#review89971 ---