[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14705068#comment-14705068
]
nicu marasoiu commented on KAFKA-1282:
--
Hi,
I noticed that the dependencies are done
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567322#comment-14567322
]
nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 2:24 PM:
--
[
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 connec
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567322#comment-14567322
]
nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 2:14 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567322#comment-14567322
]
nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 2:12 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567322#comment-14567322
]
nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 2:03 PM:
--
[
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
>
[
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
> -
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567322#comment-14567322
]
nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 2:01 PM:
--
[
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
> ---
[
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
> --
[
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 MockTim
[
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 connec
[
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
[
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
>
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567222#comment-14567222
]
nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 1:27 PM:
--
[
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 Sel
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567222#comment-14567222
]
nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 1:18 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567222#comment-14567222
]
nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 12:55 PM:
-
[
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
> --
[
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 connect
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567222#comment-14567222
]
nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 12:15 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567222#comment-14567222
]
nicu marasoiu edited comment on KAFKA-1282 at 6/1/15 12:14 PM:
-
[
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 tweake
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14208810#comment-14208810
]
nicu marasoiu commented on KAFKA-1282:
--
I want, yes, I will add a few tests this week
[
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.patch
Fixed it - I have mistakenly deleted at some point the fact th
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14203456#comment-14203456
]
nicu marasoiu commented on KAFKA-1282:
--
Indeed, I can reproduce this. I did saw an in
[
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,
>From my experiments, I noticed a new connection is always spawned
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14203334#comment-14203334
]
nicu marasoiu commented on KAFKA-1282:
--
Hi,
>From my experiments, I noticed a new co
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Attachment: 1282_brush.patch
attached, renamed time and for the "initial/reset value of the nextId
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14137796#comment-14137796
]
nicu marasoiu edited comment on KAFKA-1282 at 9/18/14 5:25 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14137796#comment-14137796
]
nicu marasoiu edited comment on KAFKA-1282 at 9/18/14 5:21 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14137796#comment-14137796
]
nicu marasoiu edited comment on KAFKA-1282 at 9/18/14 5:12 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14137796#comment-14137796
]
nicu marasoiu commented on KAFKA-1282:
--
Indeed, ack=1 solves it, it gets a reset by p
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14137118#comment-14137118
]
nicu marasoiu commented on KAFKA-1282:
--
here is a time line:
he -> produced
he -> co
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Attachment: (was: idleDisconnect.patch)
> Disconnect idle socket connection in Selector
>
[
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_the_ultimate,_close_max_one_per_select.patch)
> Disconnect idle socket
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Attachment: 1282_brushed_up.patch
re-attached fixed patch, but we may have a blocker to the whole
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14137011#comment-14137011
]
nicu marasoiu edited comment on KAFKA-1282 at 9/17/14 9:53 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14137011#comment-14137011
]
nicu marasoiu commented on KAFKA-1282:
--
Hi,
Unfortunately the client used in console
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Attachment: 1282_the_ultimate,_close_max_one_per_select.patch
Attached patch: every select iterati
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125466#comment-14125466
]
nicu marasoiu commented on KAFKA-1282:
--
[~nehanarkhede] Hi, can you also check the ne
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14125465#comment-14125465
]
nicu marasoiu commented on KAFKA-1282:
--
[~junrao], hi, can you answer please? I agree
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14122456#comment-14122456
]
nicu marasoiu commented on KAFKA-1282:
--
Hi, I am not completely sure I fully understo
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1510:
-
Attachment: Unfiltered_offsets_commit_to_kafka_rebased.patch
Attached rebased patch
> Force offse
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1510:
-
Attachment: (was: Unfiltered_to_kafka,_Incremental_to_Zookeeper.patch)
> Force offset commits
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14118294#comment-14118294
]
nicu marasoiu commented on KAFKA-1510:
--
[~jjkoshy] Hi, can you check my patch + comme
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14117638#comment-14117638
]
nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 8:55 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14117638#comment-14117638
]
nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 8:28 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14117638#comment-14117638
]
nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 8:26 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14117638#comment-14117638
]
nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 8:25 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14117638#comment-14117638
]
nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 8:18 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14117638#comment-14117638
]
nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 7:58 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14117638#comment-14117638
]
nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 7:46 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14117638#comment-14117638
]
nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 7:30 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14117638#comment-14117638
]
nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 7:29 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14117638#comment-14117638
]
nicu marasoiu edited comment on KAFKA-1282 at 9/1/14 6:57 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Attachment: idleDisconnect.patch
Wow, sorry about that:) Yes, of course, that was the intent! More
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Attachment: (was:
Patch_updated__Configurable_max_idleness_of_a_connection_since_the_last_read
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Attachment:
Patch_updated__Configurable_max_idleness_of_a_connection_since_the_last_read_on_it__O
[
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.patch)
> Disconnect idle socket connection in Selector
> -
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1510:
-
Attachment: Unfiltered_to_kafka,_Incremental_to_Zookeeper.patch
Attached a patch - I am doing unf
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1510:
-
Attachment: (was: kafka-1510.patch)
> Force offset commits when migrating consumer offsets fr
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1510:
-
Comment: was deleted
(was: The patch makes the simplest choices:
1. unfiltered commits when stora
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14115374#comment-14115374
]
nicu marasoiu commented on KAFKA-1510:
--
The patch makes the simplest choices:
1. unfi
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14114248#comment-14114248
]
nicu marasoiu commented on KAFKA-1282:
--
[~nehanarkhede] Hi, I implemented our discuss
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14114244#comment-14114244
]
nicu marasoiu commented on KAFKA-1510:
--
Hi, I will do this tomorrow, Friday, so I hop
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Attachment: (was:
kafka-1282__Disconnect_idle_socket_connection_in_Selector.patch)
> Disconn
[
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_final.patch)
> Disconnect idle socket connection in Selector
> ---
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Attachment: 1282.patch
> Disconnect idle socket connection in Selector
>
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Attachment: 1282_final.patch
uploaded with parametrization and no more access-touch from write
>
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14110261#comment-14110261
]
nicu marasoiu commented on KAFKA-1282:
--
Hi, Thank you, for 2. I agree for producers b
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14105606#comment-14105606
]
nicu marasoiu commented on KAFKA-1282:
--
After discussion with Neha, we agreed that us
[
https://issues.apache.org/jira/browse/KAFKA-1546?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu reassigned KAFKA-1546:
Assignee: nicu marasoiu
> Automate replica lag tuning
> ---
>
>
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14097380#comment-14097380
]
nicu marasoiu commented on KAFKA-1282:
--
To make the ~O(1) cost of "traversing" more c
[
https://issues.apache.org/jira/browse/KAFKA-1461?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu reassigned KAFKA-1461:
Assignee: nicu marasoiu (was: Neha Narkhede)
> Replica fetcher thread does not implement a
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14097047#comment-14097047
]
nicu marasoiu edited comment on KAFKA-1282 at 8/14/14 3:06 PM:
-
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu reassigned KAFKA-1282:
Assignee: Neha Narkhede (was: nicu marasoiu)
> Disconnect idle socket connection in Select
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14097047#comment-14097047
]
nicu marasoiu commented on KAFKA-1282:
--
Traversing is quite cheap and can be done eve
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14094686#comment-14094686
]
nicu marasoiu commented on KAFKA-1282:
--
I attached a first version of the patch.
I am
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Status: Patch Available (was: In Progress)
> Disconnect idle socket connection in Selector
> ---
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1282:
-
Attachment: kafka-1282__Disconnect_idle_socket_connection_in_Selector.patch
> Disconnect idle soc
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14094347#comment-14094347
]
nicu marasoiu commented on KAFKA-1510:
--
ok, so I have not fully understood, but what
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-1282 started by nicu marasoiu.
> Disconnect idle socket connection in Selector
> -
>
> Key: KAFK
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14090832#comment-14090832
]
nicu marasoiu edited comment on KAFKA-1282 at 8/8/14 3:37 PM:
--
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14090832#comment-14090832
]
nicu marasoiu commented on KAFKA-1282:
--
Hi,
I will spend 1-2 hours per day the next
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14083878#comment-14083878
]
nicu marasoiu commented on KAFKA-1510:
--
re-uploaded the patch
> Force offset commit
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1510:
-
Attachment: kafka-1510.patch
> Force offset commits when migrating consumer offsets from zookeepe
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1510:
-
Attachment: (was: forceCommitOnShutdownWhenDualCommit.patch)
> Force offset commits when migr
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14083551#comment-14083551
]
nicu marasoiu commented on KAFKA-1510:
--
Hi,
I have given it more consideration, and
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14082166#comment-14082166
]
nicu marasoiu commented on KAFKA-1510:
--
Hi, the "|| forceCommit" on line 318 is meant
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14079219#comment-14079219
]
nicu marasoiu commented on KAFKA-1510:
--
[~jkreps] Hi, can you please help me with fee
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14078904#comment-14078904
]
nicu marasoiu commented on KAFKA-1510:
--
[~jjkoshy] Can you please take a look at my c
[
https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu reassigned KAFKA-1549:
Assignee: Jun Rao (was: nicu marasoiu)
> dead brokers coming in the TopicMetadataResponse
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1510:
-
Assignee: Joel Koshy (was: nicu marasoiu)
Status: Patch Available (was: Open)
attached pa
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1510:
-
Comment: was deleted
(was: forcing all to zk too does indeed have the drawback that it will
typi
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
nicu marasoiu updated KAFKA-1510:
-
Comment: was deleted
(was: attached the patch with the meaning detailed in my prev comment)
> Fo
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14075447#comment-14075447
]
nicu marasoiu edited comment on KAFKA-1510 at 7/27/14 6:38 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-1510?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14075473#comment-14075473
]
nicu marasoiu edited comment on KAFKA-1510 at 7/27/14 6:34 AM:
-
[
https://issues.apache.org/jira/browse/KAFKA-1549?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14075475#comment-14075475
]
nicu marasoiu edited comment on KAFKA-1549 at 7/26/14 7:46 PM:
-
1 - 100 of 165 matches
Mail list logo
