On May 21, 2015, 12:16 a.m., Jun Rao wrote:
core/src/main/scala/kafka/coordinator/ConsumerCoordinator.scala, lines
102-106
https://reviews.apache.org/r/34450/diff/2/?file=965426#file965426line102
Another way to do this is to only load from ZK on the becoming leader
event for
Li Junjun created KAFKA-2220:
Summary: Improvement: Could we support rewind by time ?
Key: KAFKA-2220
URL: https://issues.apache.org/jira/browse/KAFKA-2220
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-2220?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Li Junjun updated KAFKA-2220:
-
Attachment: screenshot.png
Improvement: Could we support rewind by time ?
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14560387#comment-14560387
]
Jason Rosenberg edited comment on KAFKA- at 5/27/15 5:05 AM:
[
https://issues.apache.org/jira/browse/KAFKA-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14560354#comment-14560354
]
jaikiran pai commented on KAFKA-2221:
-
Created reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jaikiran pai updated KAFKA-2221:
Status: Patch Available (was: Open)
Log the entire cause which caused a reconnect in the
[
https://issues.apache.org/jira/browse/KAFKA-2221?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
jaikiran pai updated KAFKA-2221:
Attachment: KAFKA-2221.patch
Log the entire cause which caused a reconnect in the SimpleConsumer
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34697/
---
Review request for kafka.
Bugs: KAFKA-2221
[
https://issues.apache.org/jira/browse/KAFKA-2201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy resolved KAFKA-2201.
Resolution: Not A Problem
Open file handle leak
-
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14560417#comment-14560417
]
Jason Rosenberg commented on KAFKA-:
[~guozhang] I don't think so. The file
On May 26, 2015, 7:08 a.m., Michael Noll wrote:
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala, line 81
https://reviews.apache.org/r/34641/diff/1/?file=971195#file971195line81
Should we also consider reassignments that are in-progress as errors?
The
[
https://issues.apache.org/jira/browse/KAFKA-?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14560387#comment-14560387
]
Jason Rosenberg commented on KAFKA-:
Interestingly, after restarting the
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34641/#review85154
---
core/src/main/scala/kafka/admin/ReassignPartitionsCommand.scala
[
https://issues.apache.org/jira/browse/KAFKA-2201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14558885#comment-14558885
]
Albert Visagie commented on KAFKA-2201:
---
It is indeed. It would appear that the only
[
https://issues.apache.org/jira/browse/KAFKA-2201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14558885#comment-14558885
]
Albert Visagie edited comment on KAFKA-2201 at 5/26/15 8:53 AM:
I think it makes sense to take this reasonable precaution and check that
the entire message was parsed successfully at the server side.
On Tue, May 26, 2015 at 4:31 AM, Grant Henke ghe...@cloudera.com wrote:
Bumping this message again to get some input before opening a Jira.
On Thu, May 21,
[
https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Aditya A Auradkar updated KAFKA-2084:
-
Attachment: KAFKA-2084_2015-05-26_11:50:50.patch
byte rate metrics per client ID
Below are my notes. Feel free to add/ modify the content.
Kafka KIP discussion (May 26, 2015) KIP-12 (sasl/ssl authentication):
status check
Not much discussion this time.
KIP-21 (configuration management)
- Aditya will make changes to KIP-4 based on last time’s discussion.
- Andrei is OK
Hi Kafka Dev Team,
I am sorry I am new to process of discussion and/or KIP. So, I had
commented other email voting chain. Please do let me know correct process
for collecting and staring discussion with Kafka Dev Group.
Here is original message:
I have had experience with both producer and
[
https://issues.apache.org/jira/browse/KAFKA-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559567#comment-14559567
]
Jay Kreps commented on KAFKA-2217:
--
This adds a lot of allocation per select call. Is
On May 12, 2015, 7:38 p.m., Dong Lin wrote:
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java, line 117
https://reviews.apache.org/r/33049/diff/9/?file=955824#file955824line117
metric.value(timeMs), which translates to Rate.measure(config, timeMs),
may return
[
https://issues.apache.org/jira/browse/KAFKA-1944?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559488#comment-14559488
]
Ashish K Singh commented on KAFKA-1944:
---
[~omkreddy] thanks for the info. It's on my
[
https://issues.apache.org/jira/browse/KAFKA-2084?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559613#comment-14559613
]
Aditya A Auradkar commented on KAFKA-2084:
--
Updated reviewboard
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33049/
---
(Updated May 26, 2015, 6:50 p.m.)
Review request for kafka, Joel Koshy and Jun
Hi All,
This might be too late about partitioning strategy and use cases to cover.
I have had experience with both producer and consumer side. I have
different use case on this partition selection strategy.
Problem:
We have heterogeneous environment of producers (by that I mean we have
[
https://issues.apache.org/jira/browse/KAFKA-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559339#comment-14559339
]
Jason Gustafson commented on KAFKA-2217:
Updated reviewboard
[
https://issues.apache.org/jira/browse/KAFKA-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jason Gustafson updated KAFKA-2217:
---
Attachment: KAFKA-2217_2015-05-26_09:37:29.patch
Refactor Client Selectable Interface for
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33065/#review85180
---
Ship it!
Thanks for the latest patch. +1 other than the following
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34608/
---
(Updated May 26, 2015, 7:58 p.m.)
Review request for kafka.
Bugs: KAFKA-2217
On May 24, 2015, 7:16 p.m., Ewen Cheslack-Postava wrote:
clients/src/main/java/org/apache/kafka/common/network/Selector.java, line
226
https://reviews.apache.org/r/34608/diff/1/?file=969830#file969830line226
One drawback to this is that we're now constantly reallocating these
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34608/#review85245
---
I noticed one minor issue with a metrics sensor, but otherwise LGTM
[
https://issues.apache.org/jira/browse/KAFKA-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559739#comment-14559739
]
Jason Gustafson commented on KAFKA-2217:
Updated reviewboard
Andryii,
I made a few edits to this document as discussed in the KIP-21 thread.
https://cwiki.apache.org/confluence/display/KAFKA/KIP-4+-+Command+line+and+centralized+administrative+operations
With these changes. the only difference between TopicMetadataResponse_V1 and V0
is the removal of the
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34415/#review85223
---
Thanks for the patch. Just one more comment blow.
Hey everyone,
Completed the changes to KIP-4. After today's hangout, there doesn't appear to
be anything remaining to discuss on this KIP.
Please vote so we can formally close this.
Thanks,
Aditya
From: Aditya Auradkar
Sent: Thursday, May 21, 2015
- Michael
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33620/#review83993
---
On May 21, 2015, 5:37 p.m., Sriharsha Chintalapani
[
https://issues.apache.org/jira/browse/KAFKA-2217?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559646#comment-14559646
]
Jason Gustafson commented on KAFKA-2217:
KAFKA-2168 was the main reason.
[
https://issues.apache.org/jira/browse/KAFKA-2168?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559650#comment-14559650
]
Ewen Cheslack-Postava commented on KAFKA-2168:
--
Some reasons you might want
[
https://issues.apache.org/jira/browse/KAFKA-2154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559899#comment-14559899
]
Jason Gustafson commented on KAFKA-2154:
This seems like a duplicate of
Thanks for sending out the KIP notes, Ashish!
On Tue, May 26, 2015 at 11:51 AM, Ashish Singh asi...@cloudera.com wrote:
Below are my notes. Feel free to add/ modify the content.
Kafka KIP discussion (May 26, 2015) KIP-12 (sasl/ssl authentication):
status check
Not much discussion this time.
Hi, Everyone,
We will have a KIP hangout at 11 PST on May 26. The following is the
agenda. If you want to attend and is not on the invite, please let me know.
Agenda:
KIP-12 (sasl/ssl authentication): status check
KIP-21 (configuration management)
KIP-19 (Add a request timeout to NetworkClient)
[
https://issues.apache.org/jira/browse/KAFKA-1419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559172#comment-14559172
]
Adamos Loizou commented on KAFKA-1419:
--
Hello, is there any ETA on including the 2.11
[
https://issues.apache.org/jira/browse/KAFKA-1737?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14560014#comment-14560014
]
Vivek Madani edited comment on KAFKA-1737 at 5/26/15 10:38 PM:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34608/#review85192
---
Thanks for the patch. Looks good. Just a couple of minor comments
[
https://issues.apache.org/jira/browse/KAFKA-2213?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14559422#comment-14559422
]
Joel Koshy commented on KAFKA-2213:
---
Case A: Yes. i.e., if broker compression.type is
[
https://issues.apache.org/jira/browse/KAFKA-2107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Manikumar Reddy updated KAFKA-2107:
---
Status: Patch Available (was: In Progress)
Script to generate waiting-for-review report
[
https://issues.apache.org/jira/browse/KAFKA-2107?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2107 started by Manikumar Reddy.
--
Script to generate waiting-for-review report
Hi Bhavesh,
I realized I didn’t send any vote closed message on this thread.
Although the changes you are proposing related to partitioning but the change
proposed in this KIP is minor one and will benefit the users . I appreciate if
you can open up another thread for the discussion
48 matches
Mail list logo
