[jira] [Commented] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730633#comment-14730633 ] Onur Karaman commented on KAFKA-2397: - My pull request had diverged from trunk, so I f

[jira] [Created] (KAFKA-2517) Performance Regression post SSL implementation

Ben Stopford created KAFKA-2517: --- Summary: Performance Regression post SSL implementation Key: KAFKA-2517 URL: https://issues.apache.org/jira/browse/KAFKA-2517 Project: Kafka Issue Type: Bug

[jira] [Commented] (KAFKA-2431) Test SSL/TLS impact on performance

[ https://issues.apache.org/jira/browse/KAFKA-2431?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730682#comment-14730682 ] Ben Stopford commented on KAFKA-2431: - Post SSL regression in new consumer raised here

[jira] [Commented] (KAFKA-2477) Replicas spuriously deleting all segments in partition

[ https://issues.apache.org/jira/browse/KAFKA-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730713#comment-14730713 ] Håkon Hitland commented on KAFKA-2477: -- I don't see any out of sequence offsets. Here

[jira] [Commented] (KAFKA-2517) Performance Regression post SSL implementation

[ https://issues.apache.org/jira/browse/KAFKA-2517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730715#comment-14730715 ] Ismael Juma commented on KAFKA-2517: Performance improves over the baseline then? > P

[jira] [Commented] (KAFKA-2517) Performance Regression post SSL implementation

[ https://issues.apache.org/jira/browse/KAFKA-2517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730720#comment-14730720 ] Ben Stopford commented on KAFKA-2517: - That would be the implication but I am suspicio

[jira] [Commented] (KAFKA-2517) Performance Regression post SSL implementation

[ https://issues.apache.org/jira/browse/KAFKA-2517?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730726#comment-14730726 ] Ismael Juma commented on KAFKA-2517: Yes, sure. > Performance Regression post SSL imp

[jira] [Commented] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730763#comment-14730763 ] Adrian Muraru commented on KAFKA-1070: -- [~nehanarkhede] For some reason this patch wa

[jira] [Created] (KAFKA-2518) Update NOTICE file

Flavio Junqueira created KAFKA-2518: --- Summary: Update NOTICE file Key: KAFKA-2518 URL: https://issues.apache.org/jira/browse/KAFKA-2518 Project: Kafka Issue Type: Bug Components:

[jira] [Commented] (KAFKA-2510) Prevent broker from re-replicating / losing data due to disk misconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730832#comment-14730832 ] Flavio Junqueira commented on KAFKA-2510: - The key problem is the one of a broker

[jira] [Commented] (KAFKA-1929) Convert core kafka module to use the errors in org.apache.kafka.common.errors

[ https://issues.apache.org/jira/browse/KAFKA-1929?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730833#comment-14730833 ] Jeff Holoman commented on KAFKA-1929: - Jason, I'm not working on this at this time. It

[jira] [Created] (KAFKA-2519) NetworkClient.close should remove node from inFlightRequests

Ismael Juma created KAFKA-2519: -- Summary: NetworkClient.close should remove node from inFlightRequests Key: KAFKA-2519 URL: https://issues.apache.org/jira/browse/KAFKA-2519 Project: Kafka Issue

[jira] [Work started] (KAFKA-2519) NetworkClient.close should remove node from inFlightRequests

[ https://issues.apache.org/jira/browse/KAFKA-2519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2519 started by Ismael Juma. -- > NetworkClient.close should remove node from inFlightRequests >

[jira] [Commented] (KAFKA-1070) Auto-assign node id

[ https://issues.apache.org/jira/browse/KAFKA-1070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730892#comment-14730892 ] Sriharsha Chintalapani commented on KAFKA-1070: --- [~amuraru] Patch is already

[GitHub] kafka pull request: KAFKA-2519; NetworkClient.close should remove ...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/193 KAFKA-2519; NetworkClient.close should remove node from inFlightRequests You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka kafka-2519-ne

[jira] [Commented] (KAFKA-2519) NetworkClient.close should remove node from inFlightRequests

[ https://issues.apache.org/jira/browse/KAFKA-2519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14730922#comment-14730922 ] ASF GitHub Bot commented on KAFKA-2519: --- GitHub user ijuma opened a pull request:

[jira] [Updated] (KAFKA-2519) NetworkClient.close should remove node from inFlightRequests

[ https://issues.apache.org/jira/browse/KAFKA-2519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2519: --- Reviewer: Jun Rao Status: Patch Available (was: In Progress) [~junrao], can you please review t

Re: Review Request 36858: Patch for KAFKA-2120

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/36858/#review97710 --- clients/src/main/java/org/apache/kafka/clients/NetworkClient.java (

[jira] [Updated] (KAFKA-2519) NetworkClient.close should remove node from inFlightRequests

[ https://issues.apache.org/jira/browse/KAFKA-2519?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2519: --- Resolution: Fixed Status: Resolved (was: Patch Available) Issue resolved by pull request 193 [https:/

[jira] [Commented] (KAFKA-2519) NetworkClient.close should remove node from inFlightRequests

[ https://issues.apache.org/jira/browse/KAFKA-2519?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731030#comment-14731030 ] ASF GitHub Bot commented on KAFKA-2519: --- Github user asfgit closed the pull request

[GitHub] kafka pull request: KAFKA-2519; NetworkClient.close should remove ...

Github user asfgit closed the pull request at: https://github.com/apache/kafka/pull/193 --- 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 enabl

Re: [DISCUSS] KIP-31 - Message format change proposal

On Thu, Sep 3, 2015 at 11:45 PM, Jiangjie Qin wrote: > Hey Ewen, > > Thanks for the comments and they are really good questions. Please inline > replies. > > On Thu, Sep 3, 2015 at 9:35 PM, Ewen Cheslack-Postava > wrote: > > > A few questions: > > > > 1. If we update the producers to only suppor

[jira] [Commented] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731052#comment-14731052 ] Jay Kreps commented on KAFKA-2397: -- Couple thoughts: 1. [~hachikuji] Does this need to be

[jira] [Commented] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731073#comment-14731073 ] Jason Gustafson commented on KAFKA-2397: [~jkreps] Not having a way to properly le

Build failed in Jenkins: Kafka-trunk #616

See Changes: [junrao] KAFKA-2519; NetworkClient.close should remove node from inFlightRequests -- [...truncated 1662 lines...] kafka.coordinator.ConsumerCoordinatorResponseTest > testJoinGroupUnknow

Re: Review Request 36858: Patch for KAFKA-2120

> On Sept. 4, 2015, 4:07 p.m., Jun Rao wrote: > > clients/src/main/java/org/apache/kafka/clients/NetworkClient.java, lines > > 362-367 > > > > > > But those closed connections are only added to the disconnected list

[jira] [Commented] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731091#comment-14731091 ] Jay Kreps commented on KAFKA-2397: -- [~hachikuji] Makes sense. > leave group request > --

[GitHub] kafka pull request: KAFKA-2491; update ErrorMapping with new consu...

Github user hachikuji closed the pull request at: https://github.com/apache/kafka/pull/188 --- 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 en

[jira] [Commented] (KAFKA-2491) Update ErrorMapping with New Consumer Errors

[ https://issues.apache.org/jira/browse/KAFKA-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731126#comment-14731126 ] ASF GitHub Bot commented on KAFKA-2491: --- Github user hachikuji closed the pull reque

[jira] [Updated] (KAFKA-2491) Update ErrorMapping with New Consumer Errors

[ https://issues.apache.org/jira/browse/KAFKA-2491?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jason Gustafson updated KAFKA-2491: --- Resolution: Not A Problem Status: Resolved (was: Patch Available) Already fixed in th

[jira] [Commented] (KAFKA-2477) Replicas spuriously deleting all segments in partition

[ https://issues.apache.org/jira/browse/KAFKA-2477?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731210#comment-14731210 ] Jun Rao commented on KAFKA-2477: Thanks. Then the log looks normal. The only thing that I

[jira] [Commented] (KAFKA-2513) Checkstyle is not executed until gradle's tests phase

[ https://issues.apache.org/jira/browse/KAFKA-2513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731262#comment-14731262 ] Ashish K Singh commented on KAFKA-2513: --- I was suggesting this as nice to have. Howe

[jira] [Resolved] (KAFKA-2513) Checkstyle is not executed until gradle's tests phase

[ https://issues.apache.org/jira/browse/KAFKA-2513?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ashish K Singh resolved KAFKA-2513. --- Resolution: Won't Fix > Checkstyle is not executed until gradle's tests phase > --

[jira] [Commented] (KAFKA-2513) Checkstyle is not executed until gradle's tests phase

[ https://issues.apache.org/jira/browse/KAFKA-2513?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731295#comment-14731295 ] Ismael Juma commented on KAFKA-2513: [~ewencp], by your argument, checkstyle shouldn't

[jira] [Commented] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731364#comment-14731364 ] Onur Karaman commented on KAFKA-2397: - Here's a summary of what I think each approach

[jira] [Commented] (KAFKA-2397) leave group request

[ https://issues.apache.org/jira/browse/KAFKA-2397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731373#comment-14731373 ] Jiangjie Qin commented on KAFKA-2397: - [~jkreps] using TCP close to signal disconnect

[jira] [Commented] (KAFKA-2500) Make logEndOffset available in the 0.8.3 Consumer

[ https://issues.apache.org/jira/browse/KAFKA-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731378#comment-14731378 ] Jason Gustafson commented on KAFKA-2500: [~willf] I realized that there is already

[GitHub] kafka pull request: Kafka-2440; Use `NetworkClient` instead of `Si...

GitHub user ijuma opened a pull request: https://github.com/apache/kafka/pull/194 Kafka-2440; Use `NetworkClient` instead of `SimpleConsumer` to fetch data from replica You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kafka

[jira] [Commented] (KAFKA-2510) Prevent broker from re-replicating / losing data due to disk misconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731393#comment-14731393 ] Jiangjie Qin commented on KAFKA-2510: - Hey Gwen, can you elaborate a bit why the consu

[jira] [Commented] (KAFKA-2440) Use `NetworkClient` instead of `SimpleConsumer` to fetch data from replica

[ https://issues.apache.org/jira/browse/KAFKA-2440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731401#comment-14731401 ] ASF GitHub Bot commented on KAFKA-2440: --- GitHub user ijuma reopened a pull request:

[GitHub] kafka pull request: KAFKA-2440; Use `NetworkClient` instead of `Si...

GitHub user ijuma reopened a pull request: https://github.com/apache/kafka/pull/194 KAFKA-2440; Use `NetworkClient` instead of `SimpleConsumer` to fetch data from replica You can merge this pull request into a Git repository by running: $ git pull https://github.com/ijuma/kaf

[GitHub] kafka pull request: KAFKA-2440; Use `NetworkClient` instead of `Si...

Github user ijuma closed the pull request at: https://github.com/apache/kafka/pull/194 --- 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 enable

[jira] [Commented] (KAFKA-2440) Use `NetworkClient` instead of `SimpleConsumer` to fetch data from replica

[ https://issues.apache.org/jira/browse/KAFKA-2440?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731400#comment-14731400 ] ASF GitHub Bot commented on KAFKA-2440: --- Github user ijuma closed the pull request a

[jira] [Commented] (KAFKA-2510) Prevent broker from re-replicating / losing data due to disk misconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731403#comment-14731403 ] Gwen Shapira commented on KAFKA-2510: - the old data directory will be untouched, but b

[jira] [Updated] (KAFKA-2440) Use `NetworkClient` instead of `SimpleConsumer` to fetch data from replica

[ https://issues.apache.org/jira/browse/KAFKA-2440?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ismael Juma updated KAFKA-2440: --- Reviewer: Jun Rao Status: Patch Available (was: In Progress) I submitted a PR for this. `Networ

[jira] [Commented] (KAFKA-2510) Prevent broker from re-replicating / losing data due to disk misconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731497#comment-14731497 ] Jay Kreps commented on KAFKA-2510: -- I actually think we shouldn't prevent this. In our r

[jira] [Comment Edited] (KAFKA-2510) Prevent broker from re-replicating / losing data due to disk misconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731497#comment-14731497 ] Jay Kreps edited comment on KAFKA-2510 at 9/4/15 9:56 PM: -- I actu

[GitHub] kafka pull request: KAFKA-2211: Adding simpleAclAuthorizer impleme...

GitHub user Parth-Brahmbhatt opened a pull request: https://github.com/apache/kafka/pull/195 KAFKA-2211: Adding simpleAclAuthorizer implementation and test cases. You can merge this pull request into a Git repository by running: $ git pull https://github.com/Parth-Brahmbhatt/k

[jira] [Commented] (KAFKA-2211) KafkaAuthorizer: Add simpleACLAuthorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731532#comment-14731532 ] ASF GitHub Bot commented on KAFKA-2211: --- GitHub user Parth-Brahmbhatt opened a pull

[jira] [Updated] (KAFKA-2211) KafkaAuthorizer: Add simpleACLAuthorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Parth Brahmbhatt updated KAFKA-2211: Status: Patch Available (was: In Progress) > KafkaAuthorizer: Add simpleACLAuthorizer imple

[jira] [Work started] (KAFKA-2211) KafkaAuthorizer: Add simpleACLAuthorizer implementation.

[ https://issues.apache.org/jira/browse/KAFKA-2211?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Work on KAFKA-2211 started by Parth Brahmbhatt. --- > KafkaAuthorizer: Add simpleACLAuthorizer implementation. > --

[jira] [Commented] (KAFKA-2500) Make logEndOffset available in the 0.8.3 Consumer

[ https://issues.apache.org/jira/browse/KAFKA-2500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731538#comment-14731538 ] Will Funnell commented on KAFKA-2500: - [~hachikuji] From my understanding it would see

Re: Review Request 34493: Patch for KAFKA-2211

> On Aug. 23, 2015, 9:28 p.m., Jun Rao wrote: > > core/src/main/scala/kafka/security/auth/SimpleAclAuthorizer.scala, lines > > 55-57 > > > > > > To be consistent with how we pass in configs for pluggable components, >

Re: Review Request 34493: Patch for KAFKA-2211

> On Aug. 21, 2015, 2:31 p.m., Ismael Juma wrote: > > Thanks for this Parth. I did an initial pass where I left a number comments > > (many of them style-related, see http://kafka.apache.org/coding-guide.html > > for reference). I know, we should have a tool that checks some of these > > thing

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731570#comment-14731570 ] Tapasi Paul commented on KAFKA-2120: Hello folks, We are facing an issue with the

Contributor List

Hi can i get added to the contributor list? I'd like to take crack at KAFKA-2058 Thanks! Bill Bejeck

Re: Contributor List

Thank you! Please create a Jira user if you didn't do so already, and let me know your user name. I'll add you to the list. On Fri, Sep 4, 2015 at 4:33 PM, Bill Bejeck wrote: > Hi can i get added to the contributor list? I'd like to take crack at > KAFKA-2058

[jira] [Commented] (KAFKA-2510) Prevent broker from re-replicating / losing data due to disk misconfiguration

[ https://issues.apache.org/jira/browse/KAFKA-2510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731629#comment-14731629 ] Gwen Shapira commented on KAFKA-2510: - [~jkreps] I agree that this capability is impor

Re: Review Request 36858: Patch for KAFKA-2120

--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/36858/ --- (Updated Sept. 5, 2015, 12:49 a.m.) Review request for kafka. Bugs: KAFKA-212

[jira] [Updated] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Mayuresh Gharat updated KAFKA-2120: --- Attachment: KAFKA-2120_2015-09-04_17:49:01.patch > Add a request timeout to NetworkClient > --

[jira] [Commented] (KAFKA-2120) Add a request timeout to NetworkClient

[ https://issues.apache.org/jira/browse/KAFKA-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14731670#comment-14731670 ] Mayuresh Gharat commented on KAFKA-2120: Updated reviewboard https://reviews.apach