[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: 1282_access-order_+_test_single_conn.patch Hi, Added a test. I think it can be

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567222#comment-14567222 ] nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 12:55 PM:

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567222#comment-14567222 ] nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 12:14 PM:

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567222#comment-14567222 ] nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 12:15 PM:

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: (was: 1282_access-order_+_test_single_conn.patch) Disconnect idle socket

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: access-order_+_test.patch Disconnect idle socket connection in Selector

[jira] [Commented] (KAFKA-2187) Introduce merge-kafka-pr.py script

2015-06-01 Thread Ismael Juma (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567032#comment-14567032 ] Ismael Juma commented on KAFKA-2187: Sure, that was indeed my plan. Will do it soon.

Re: [VOTE] KIP-21 Dynamic Configuration

2015-06-01 Thread Jay Kreps
Awesome. +1 On Sunday, May 31, 2015, Aditya Auradkar aaurad...@linkedin.com.invalid wrote: 2. There was a typo in my previous email. I meant to say that we should use snake case because it's more consistent. I couldn't find any examples of camel case but did find some snake case (jmx_port).

RE: [VOTE] KIP-21 Dynamic Configuration

2015-06-01 Thread Aditya Auradkar
Thanks Jay. Since we have enough votes now, I'll mark this as adopted. Aditya From: Jay Kreps [jay.kr...@gmail.com] Sent: Monday, June 01, 2015 8:42 AM To: dev@kafka.apache.org Subject: Re: [VOTE] KIP-21 Dynamic Configuration Awesome. +1 On Sunday, May

KIP Wiki

2015-06-01 Thread Aditya Auradkar
Hey everyone, We have enough KIP's now (25) that it's a bit hard to tell which ones are adopted or under discussion by glancing at the wiki. Any concerns if I split it into 3 tables (adopted, discarded and KIP's under discussion)?

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: (was: 1282_access-order.patch) Disconnect idle socket connection in Selector

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567322#comment-14567322 ] nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 2:01 PM: --

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: (was: 1282_brushed_up.patch) Disconnect idle socket connection in Selector

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567322#comment-14567322 ] nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 2:14 PM: --

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567322#comment-14567322 ] nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 2:03 PM: --

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567322#comment-14567322 ] nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 2:12 PM: --

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: access_order_+_test_waiting_from_350ms_to_1100ms.patch Disconnect idle socket

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567222#comment-14567222 ] nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 1:18 PM: --

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: 1282_access-order_+_test_(same_class).patch Disconnect idle socket connection in

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: (was: 1282_access-order_+_test_(same_class).patch) Disconnect idle socket

[jira] [Issue Comment Deleted] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Comment: was deleted (was: Hi [~junrao], [~nehanarkhede], I added a straight test. I saw on my

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: (was: access-order_+_test.patch) Disconnect idle socket connection in Selector

[jira] [Updated] (KAFKA-2234) Partition reassignment of a nonexistent topic prevents future reassignments

2015-06-01 Thread Bob Halley (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2234?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Bob Halley updated KAFKA-2234: -- Summary: Partition reassignment of a nonexistent topic prevents future reassignments (was: Partition

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: 1282_access-order_+_test_(same_class).patch Added a test. I wanted to sleep on

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: access-order_+_test.patch Disconnect idle socket connection in Selector

[jira] [Created] (KAFKA-2234) Partition reassignment of an empty topic prevents future reassignments

2015-06-01 Thread Bob Halley (JIRA)
Bob Halley created KAFKA-2234: - Summary: Partition reassignment of an empty topic prevents future reassignments Key: KAFKA-2234 URL: https://issues.apache.org/jira/browse/KAFKA-2234 Project: Kafka

[jira] [Updated] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] nicu marasoiu updated KAFKA-1282: - Attachment: (was: 1282_brush.patch) Disconnect idle socket connection in Selector

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567222#comment-14567222 ] nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 1:27 PM: --

[jira] [Comment Edited] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread nicu marasoiu (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567322#comment-14567322 ] nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 2:24 PM: --

[jira] [Commented] (KAFKA-2231) Deleting a topic fails

2015-06-01 Thread Onur Karaman (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14567640#comment-14567640 ] Onur Karaman commented on KAFKA-2231: - Can you provide the number of partitions for

Re: KIP Wiki

2015-06-01 Thread Ashish Singh
I like the idea! On Mon, Jun 1, 2015 at 9:51 AM, Aditya Auradkar aaurad...@linkedin.com.invalid wrote: Hey everyone, We have enough KIP's now (25) that it's a bit hard to tell which ones are adopted or under discussion by glancing at the wiki. Any concerns if I split it into 3 tables

Re: KIP Wiki

2015-06-01 Thread Jiangjie Qin
+1 On 6/1/15, 11:53 AM, Ashish Singh asi...@cloudera.com wrote: I like the idea! On Mon, Jun 1, 2015 at 9:51 AM, Aditya Auradkar aaurad...@linkedin.com.invalid wrote: Hey everyone, We have enough KIP's now (25) that it's a bit hard to tell which ones are adopted or under discussion by

[jira] [Updated] (KAFKA-2235) LogCleaner offset map overflow

2015-06-01 Thread Ivan Simoneko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Simoneko updated KAFKA-2235: - Status: Patch Available (was: Open) LogCleaner offset map overflow

[jira] [Created] (KAFKA-2235) LogCleaner offset map overflow

2015-06-01 Thread Ivan Simoneko (JIRA)
Ivan Simoneko created KAFKA-2235: Summary: LogCleaner offset map overflow Key: KAFKA-2235 URL: https://issues.apache.org/jira/browse/KAFKA-2235 Project: Kafka Issue Type: Bug

Re: Review Request 34734: Patch for KAFKA-2226

2015-06-01 Thread Onur Karaman
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/34734/#review86047 --- Ran the patch with the following command 60+ times and didn't see

[jira] [Updated] (KAFKA-2235) LogCleaner offset map overflow

2015-06-01 Thread Ivan Simoneko (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Ivan Simoneko updated KAFKA-2235: - Attachment: KAFKA-2235_v1.patch LogCleaner offset map overflow --

[jira] [Updated] (KAFKA-2226) NullPointerException in TestPurgatoryPerformance

2015-06-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2226?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Jun Rao updated KAFKA-2226: --- Resolution: Fixed Fix Version/s: 0.8.3 Status: Resolved (was: Patch Available) Thanks for

Re: Anyone else sees SocketServerTest failing on trunk?

2015-06-01 Thread Jun Rao
Hmm, don't see the failure myself. Thanks, Jun On Sun, May 31, 2015 at 2:30 PM, Gwen Shapira gshap...@cloudera.com wrote: Hi, I'm running: ./gradlew cleanTest test on trunk and all of SocketServerTest tests are failing with: java.net.SocketException: Socket closed at

[jira] [Commented] (KAFKA-2231) Deleting a topic fails

2015-06-01 Thread James G. Haberly (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568122#comment-14568122 ] James G. Haberly commented on KAFKA-2231: - I'm not certain what information this

[jira] [Commented] (KAFKA-2231) Deleting a topic fails

2015-06-01 Thread James G. Haberly (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568118#comment-14568118 ] James G. Haberly commented on KAFKA-2231: - It is a test system. 1 ZooKeeper

Re: Review Request 34789: Patch for KAFKA-2168

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

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

2015-06-01 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-01_16:03:38.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-01 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568198#comment-14568198 ] Jason Gustafson commented on KAFKA-2168: Updated reviewboard

Re: Review Request 33065: Patch for KAFKA-1928

2015-06-01 Thread Jay Kreps
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33065/#review86117 ---

Re: Review Request 33065: Patch for KAFKA-1928

2015-06-01 Thread Jay Kreps
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33065/#review86118 --- Ship it! Looks good to me. - Jay Kreps On May 31, 2015, 9:49

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

2015-06-01 Thread Jason Gustafson (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568212#comment-14568212 ] Jason Gustafson commented on KAFKA-2168: The most recent patch attempts to follow

Re: Review Request 33065: Patch for KAFKA-1928

2015-06-01 Thread Jun Rao
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/33065/#review86095 --- Thanks for the latest patch. A few more minor comments below.

[jira] [Commented] (KAFKA-1282) Disconnect idle socket connection in Selector

2015-06-01 Thread Jun Rao (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14568257#comment-14568257 ] Jun Rao commented on KAFKA-1282: [~nmarasoi], thanks for the patch. We are changing

[jira] [Updated] (KAFKA-2236) offset request reply racing with segment rolling

2015-06-01 Thread Alfred Landrum (JIRA)
[ https://issues.apache.org/jira/browse/KAFKA-2236?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Alfred Landrum updated KAFKA-2236: -- Description: My use case with kafka involves an aggressive retention policy that rolls segment

Re: KIP Wiki

2015-06-01 Thread Joe Stein
We should probably have some release/vXYZ section so that over time we can keep track of what KIP where approved for what release, etc/ Anything not in a release folder (we could do now release/v0.8.3.0 for everything already approved) would be where it is deemed under discussion, or such. ~ Joe

[jira] [Created] (KAFKA-2236) offset request reply racing with segment rolling

2015-06-01 Thread Alfred Landrum (JIRA)
Alfred Landrum created KAFKA-2236: - Summary: offset request reply racing with segment rolling Key: KAFKA-2236 URL: https://issues.apache.org/jira/browse/KAFKA-2236 Project: Kafka Issue Type:

Re: [DISCUSS] KIP-19 Add a request timeout to NetworkClient

2015-06-01 Thread Jiangjie Qin
Bump up this thread. After several discussions in LinkedIn, we came up with three options. I have updated the KIP-19 wiki page to summarize the three options and stated our preference. We can discuss on them in tomorrow’s KIP hangout. Please let us know what do you think. Thanks, Jiangjie

Re: KIP Wiki

2015-06-01 Thread Neha Narkhede
+1. Thanks Aditya! On Mon, Jun 1, 2015 at 7:34 PM, Mayuresh Gharat gharatmayures...@gmail.com wrote: +1. Thanks, Mayuresh On Mon, Jun 1, 2015 at 6:51 PM, Joe Stein joe.st...@stealth.ly wrote: We should probably have some release/vXYZ section so that over time we can keep track of