Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Edward Ribeiro
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/#review92349 --- core/src/main/scala/kafka/security/auth/Acl.scala (line 136)

Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Edward Ribeiro
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/#review92350 --- core/src/main/scala/kafka/server/KafkaApis.scala (line 620)

Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Edward Ribeiro
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/#review92352 --- core/src/main/scala/kafka/security/auth/KafkaPrincipal.scala (line

Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Edward Ribeiro
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/#review92354 --- core/src/main/scala/kafka/security/auth/Operation.scala (line 43)

Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Edward Ribeiro
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/#review92355 --- core/src/main/scala/kafka/server/KafkaApis.scala (line 148)

Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Edward Ribeiro
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/#review92356 --- core/src/main/scala/kafka/server/KafkaApis.scala (line 536)

Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Edward Ribeiro
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/#review92357 --- core/src/main/scala/kafka/server/KafkaApis.scala (line 136)

Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Edward Ribeiro
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/#review92358 --- core/src/main/scala/kafka/server/KafkaApis.scala (line 163)

Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Edward Ribeiro
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/#review92359 --- core/src/main/scala/kafka/security/auth/PermissionType.scala (line

Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Edward Ribeiro
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/#review92361 --- core/src/main/scala/kafka/security/auth/PermissionType.scala (line

Re: Review Request 33620: Patch for KAFKA-1690

2015-07-20 Thread Sriharsha Chintalapani
On June 30, 2015, 3:03 p.m., Jun Rao wrote: clients/src/main/java/org/apache/kafka/common/network/SSLTransportLayer.java, line 67 https://reviews.apache.org/r/33620/diff/10/?file=990783#file990783line67 Shouldn't we only start the ssl handshake after the raw socket connection

Re: Review Request 33620: Patch for KAFKA-1690

2015-07-20 Thread Sriharsha Chintalapani
On June 30, 2015, 3:03 p.m., Jun Rao wrote: core/src/main/scala/kafka/network/SocketServer.scala, line 393 https://reviews.apache.org/r/33620/diff/10/?file=990801#file990801line393 This parameter doesn't seem to be used. We can remove it. I am using for metrics On June 30, 2015,

Re: Review Request 33620: Patch for KAFKA-1690

2015-07-20 Thread Sriharsha Chintalapani
On June 30, 2015, 5:20 p.m., Joel Koshy wrote: clients/src/main/java/org/apache/kafka/common/network/Channel.java, lines 148-150 https://reviews.apache.org/r/33620/diff/10/?file=990775#file990775line148 This should be caught by checkstyle - can you double-check? If we want

Re: Review Request 33620: Patch for KAFKA-1690

2015-07-20 Thread Sriharsha Chintalapani
On June 24, 2015, 4:39 p.m., Jiangjie Qin wrote: clients/src/main/java/org/apache/kafka/common/network/SSLTransportLayer.java, lines 75-78 https://reviews.apache.org/r/33620/diff/10/?file=990783#file990783line75 Can they be replaced by clear() method? These are set only once I

Re: Review Request 33620: Patch for KAFKA-1690

2015-07-20 Thread Sriharsha Chintalapani
On May 22, 2015, 12:33 a.m., Jun Rao wrote: clients/src/main/java/org/apache/kafka/common/network/SSLTransportLayer.java, line 294 https://reviews.apache.org/r/33620/diff/8/?file=966806#file966806line294 Not sure why we are looping back here. If the HandshakeStatus is

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

2015-07-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634169#comment-14634169 ] Jason Gustafson commented on KAFKA-2350: There will probably be a large number of

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

2015-07-20 Thread Yasuhiro Matsuda (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634229#comment-14634229 ] Yasuhiro Matsuda commented on KAFKA-2350: - Can we have TopicPartition rather than

[jira] [Commented] (KAFKA-2342) transient unit test failure in testConsumptionWithBrokerFailures

2015-07-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634274#comment-14634274 ] Jason Gustafson commented on KAFKA-2342: [~junrao], I found a case where a

Build failed in Jenkins: KafkaPreCommit #158

2015-07-20 Thread Apache Jenkins Server
See https://builds.apache.org/job/KafkaPreCommit/158/changes Changes: [cshapi] KAFKA-2337; Verify that metric names will not collide when creating new topics; patched by Grant Henke; reviewed by Edward Ribeiro, Ashish Singh and Gwen Shapira --

Build failed in Jenkins: KafkaPreCommit #159

2015-07-20 Thread Apache Jenkins Server
See https://builds.apache.org/job/KafkaPreCommit/159/changes Changes: [cshapi] KAFKA-2328; merge-kafka-pr.py script should not leave user in a detached branch -- [...truncated 803 lines...] kafka.log.OffsetMapTest testClear PASSED

Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Edward Ribeiro
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/#review92341 --- core/src/main/scala/kafka/security/auth/Acl.scala (line 86)

Re: [DISCUSS] KIP-27 - Conditional Publish

2015-07-20 Thread Ben Kirwin
Yes, sorry, I think this is right -- it's pretty application-specific. One thing to note: in a large subset of cases (ie. bulk load, copycat-type, mirrormaker) the correct response is not to resend the message at all; if there's already a message at that offset, it's because another instance of

[jira] [Commented] (KAFKA-2337) Verify that metric names will not collide when creating new topics

2015-07-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634247#comment-14634247 ] Gwen Shapira commented on KAFKA-2337: - Pushed to trunk. Thanks for the patch

[jira] [Updated] (KAFKA-2328) merge-kafka-pr.py script should not leave user in a detached branch

2015-07-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2328: Resolution: Fixed Reviewer: Gwen Shapira Fix Version/s: 0.8.3 Status:

[jira] [Comment Edited] (KAFKA-2350) Add KafkaConsumer pause capability

2015-07-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634294#comment-14634294 ] Jason Gustafson edited comment on KAFKA-2350 at 7/20/15 11:49 PM:

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

2015-07-20 Thread Edward Ribeiro (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634296#comment-14634296 ] Edward Ribeiro commented on KAFKA-2350: --- Nit: wouldn't the inverse of ``pause`` to

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

2015-07-20 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634294#comment-14634294 ] Jason Gustafson commented on KAFKA-2350: I don't see why not. In that case, I

[jira] [Commented] (KAFKA-2350) Add KafkaConsumer pause capability

2015-07-20 Thread Yasuhiro Matsuda (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2350?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634322#comment-14634322 ] Yasuhiro Matsuda commented on KAFKA-2350: - To me the state preservation is not a

[jira] [Commented] (KAFKA-2329) Consumers balance fails when multiple consumers are started simultaneously.

2015-07-20 Thread Guozhang Wang (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2329?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634222#comment-14634222 ] Guozhang Wang commented on KAFKA-2329: -- Thanks for the patch [~zklapow], a couple

[jira] [Commented] (KAFKA-2342) transient unit test failure in testConsumptionWithBrokerFailures

2015-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2342?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634266#comment-14634266 ] ASF GitHub Bot commented on KAFKA-2342: --- GitHub user hachikuji opened a pull

[GitHub] kafka pull request: KAFKA-2342; fix transient unit test failure Co...

2015-07-20 Thread hachikuji
GitHub user hachikuji opened a pull request: https://github.com/apache/kafka/pull/88 KAFKA-2342; fix transient unit test failure ConsumerBounceTest You can merge this pull request into a Git repository by running: $ git pull https://github.com/hachikuji/kafka KAFKA-2342

[GitHub] kafka pull request: Fixed javadoc for committed return value

2015-07-20 Thread sslavic
GitHub user sslavic opened a pull request: https://github.com/apache/kafka/pull/89 Fixed javadoc for committed return value If no offset has been committed, then committed method does not return (null) value, instead NoOffsetForPartitionException is thrown in that case. You can

[jira] [Commented] (KAFKA-2328) merge-kafka-pr.py script should not leave user in a detached branch

2015-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2328?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634279#comment-14634279 ] ASF GitHub Bot commented on KAFKA-2328: --- Github user asfgit closed the pull request

Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Parth Brahmbhatt
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34492/ --- (Updated July 20, 2015, 11:42 p.m.) Review request for kafka. Bugs:

[GitHub] kafka pull request: KAFKA-2328; merge-kafka-pr.py script should no...

2015-07-20 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/84 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

2015-07-20 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634280#comment-14634280 ] Parth Brahmbhatt commented on KAFKA-2210: - Updated reviewboard

Re: Review Request 34492: Patch for KAFKA-2210

2015-07-20 Thread Parth Brahmbhatt
On July 16, 2015, 10:32 p.m., Edward Ribeiro wrote: core/src/main/scala/kafka/security/auth/Operation.scala, lines 43-44 https://reviews.apache.org/r/34492/diff/7/?file=1011774#file1011774line43 +1. As of today, it spills out a Match error that can be confusing to figure out. An

[jira] [Updated] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

2015-07-20 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Parth Brahmbhatt updated KAFKA-2210: Attachment: KAFKA-2210_2015-07-20_16:42:18.patch KafkaAuthorizer: Add all public entities,

[jira] [Updated] (KAFKA-2210) KafkaAuthorizer: Add all public entities, config changes and changes to KafkaAPI and kafkaServer to allow pluggable authorizer implementation.

2015-07-20 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2210?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Parth Brahmbhatt updated KAFKA-2210: Status: Patch Available (was: In Progress) KafkaAuthorizer: Add all public entities,

[jira] [Commented] (KAFKA-824) java.lang.NullPointerException in commitOffsets

2015-07-20 Thread Parth Brahmbhatt (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-824?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634327#comment-14634327 ] Parth Brahmbhatt commented on KAFKA-824: [~junrao] Looked at the fix code and

Jenkins build is back to normal : Kafka-trunk #550

2015-07-20 Thread Apache Jenkins Server
See https://builds.apache.org/job/Kafka-trunk/550/changes

[jira] [Updated] (KAFKA-2337) Verify that metric names will not collide when creating new topics

2015-07-20 Thread Grant Henke (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2337?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Grant Henke updated KAFKA-2337: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available)

[jira] [Commented] (KAFKA-2100) Client Error doesn't preserve or display original server error code when it is an unknown code

2015-07-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634435#comment-14634435 ] Gwen Shapira commented on KAFKA-2100: - Go ahead, all yours :) Client Error doesn't

[jira] [Updated] (KAFKA-2100) Client Error doesn't preserve or display original server error code when it is an unknown code

2015-07-20 Thread Gwen Shapira (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2100?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gwen Shapira updated KAFKA-2100: Assignee: David Jacot (was: Gwen Shapira) Client Error doesn't preserve or display original

[jira] [Commented] (KAFKA-2338) Warn users if they change max.message.bytes that they also need to update broker and consumer settings

2015-07-20 Thread Edward Ribeiro (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2338?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634465#comment-14634465 ] Edward Ribeiro commented on KAFKA-2338: --- Hi [~gwenshap], whenever you have a free

[jira] [Created] (KAFKA-2351) Brokers are having a problem shutting down correctly

2015-07-20 Thread Mayuresh Gharat (JIRA)
Mayuresh Gharat created KAFKA-2351: -- Summary: Brokers are having a problem shutting down correctly Key: KAFKA-2351 URL: https://issues.apache.org/jira/browse/KAFKA-2351 Project: Kafka Issue

[GitHub] kafka pull request: KAFKA-1621 : Standardize --messages option

2015-07-20 Thread rekhajoshm
Github user rekhajoshm closed the pull request at: https://github.com/apache/kafka/pull/58 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the feature is

[jira] [Commented] (KAFKA-1621) Standardize --messages option in perf scripts

2015-07-20 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1621?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14634555#comment-14634555 ] ASF GitHub Bot commented on KAFKA-1621: --- Github user rekhajoshm closed the pull

<    1   2