+1. Thanks Aditya!
On Mon, Jun 1, 2015 at 7:34 PM, Mayuresh Gharat
wrote:
> +1.
>
> Thanks,
>
> Mayuresh
>
> On Mon, Jun 1, 2015 at 6:51 PM, Joe Stein wrote:
>
> > We should probably have some release/vXYZ section so that over time we
> can
> > keep track of what KIP where approved for what rel
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 (Becke
[
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
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:
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14568476#comment-14568476
]
Guozhang Wang commented on KAFKA-:
--
Today we have IO error handling in KafkaApi's
+1.
Thanks,
Mayuresh
On Mon, Jun 1, 2015 at 6:51 PM, Joe Stein wrote:
> 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
> everyth
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
+1
On Mon, Jun 1, 2015 at 12:00 PM, Jiangjie Qin
wrote:
> +1
>
> On 6/1/15, 11:53 AM, "Ashish Singh" 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)
Bhavesh,
I am not sure if load balancing based on the consumption rate (1.b) makes
sense. Each consumer typically consumes all partitions from a topic. So, as
long as the data in each partition is balanced, the consumption rate will
be balanced too. Selecting a partition based on the size of each
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34524/#review86101
---
It'd rather avoid mixing coordinator failover optimization logic wit
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-1282:
---
Status: In Progress (was: Patch Available)
> Disconnect idle socket connection in Selector
>
[
https://issues.apache.org/jira/browse/KAFKA-1282?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14568257#comment-14568257
]
Jun Rao commented on KAFKA-1282:
[~nmarasoi], thanks for the patch. We are changing Socket
---
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.
clie
---
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 p.m
[
https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14568212#comment-14568212
]
Jason Gustafson commented on KAFKA-2168:
The most recent patch attempts to follow
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33065/#review86117
---
clients/src/main/java/org/apache/kafka/common/network/Selector.java
[
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 l
---
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: KAFKA-2168
[
https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14568198#comment-14568198
]
Jason Gustafson commented on KAFKA-2168:
Updated reviewboard https://reviews.apach
[
https://issues.apache.org/jira/browse/KAFKA-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14568122#comment-14568122
]
James G. Haberly commented on KAFKA-2231:
-
I'm not certain what information this w
[
https://issues.apache.org/jira/browse/KAFKA-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14568118#comment-14568118
]
James G. Haberly commented on KAFKA-2231:
-
It is a test system. 1 ZooKeeper insta
Hmm, don't see the failure myself.
Thanks,
Jun
On Sun, May 31, 2015 at 2:30 PM, Gwen Shapira wrote:
> Hi,
>
> I'm running:
> ./gradlew cleanTest test
>
> on trunk and all of SocketServerTest tests are failing with:
> java.net.SocketException: Socket closed
> at java.net.PlainSocket
[
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 t
[
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
> --
[
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
> --
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
Compon
---
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 an
+1
On 6/1/15, 11:53 AM, "Ashish Singh" 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 gl
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 table
[
https://issues.apache.org/jira/browse/KAFKA-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567640#comment-14567640
]
Onur Karaman commented on KAFKA-2231:
-
Can you provide the number of partitions for th
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)?
https://cwiki.apache.org/confluence/display/KAFKA/Kafka+Improveme
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 3
Awesome. +1
On Sunday, May 31, 2015, Aditya Auradkar
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). Other than that,
> most other
[
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-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 re
[
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
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
[
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-2187?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14567032#comment-14567032
]
Ismael Juma commented on KAFKA-2187:
Sure, that was indeed my plan. Will do it soon.
59 matches
Mail list logo
