. To reply, visit:
https://reviews.apache.org/r/36034/#review90730
---
On July 7, 2015, 5:47 p.m., Dong Lin wrote:
---
This is an automatically generated e-mail. To reply, visit:
https
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14615622#comment-14615622
]
Dong Lin commented on KAFKA-2298:
-
Joel, could you please review this patch when you have
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14615627#comment-14615627
]
Dong Lin edited comment on KAFKA-2241 at 7/6/15 8:48 PM:
-
Hi
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14615627#comment-14615627
]
Dong Lin commented on KAFKA-2241:
-
Hi [~junrao]], could you please review this patch when
5671a3fbeea8cb9a9ffeeb41aa1b132b92c0cae8
clients/src/main/java/org/apache/kafka/clients/producer/internals/Sender.java
0baf16e55046a2f49f6431e01d52c323c95eddf0
Diff: https://reviews.apache.org/r/36034/diff/
Testing
---
Thanks,
Dong Lin
-exhausted with a different name.
I prefer the first option since I feel in practice people just want to
distinguish between the case that messages failed to get into the producer
from the case the messages gets failed to send to the broker.
Dong Lin wrote:
Thanks for your comments. If I
-exhausted with a different name.
I prefer the first option since I feel in practice people just want to
distinguish between the case that messages failed to get into the producer
from the case the messages gets failed to send to the broker.
Dong Lin wrote:
Thanks for your comments. If I
[
https://issues.apache.org/jira/browse/KAFKA-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2306:
Attachment: KAFKA-2306_2015-07-06_14:54:01.patch
New producer should emit metrics for buffer exhaustion
[
https://issues.apache.org/jira/browse/KAFKA-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14615736#comment-14615736
]
Dong Lin commented on KAFKA-2306:
-
Updated reviewboard https://reviews.apache.org/r/36034
-mail. To reply, visit:
https://reviews.apache.org/r/36034/#review90303
---
On June 30, 2015, 4:04 a.m., Dong Lin wrote:
---
This is an automatically generated e-mail. To reply
[
https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2191:
Resolution: Fixed
Status: Resolved (was: Patch Available)
Merged into KAFKA-2084.
Measured rate
/kafka/clients/producer/internals/Sender.java
0baf16e55046a2f49f6431e01d52c323c95eddf0
Diff: https://reviews.apache.org/r/36034/diff/
Testing
---
Thanks,
Dong Lin
[
https://issues.apache.org/jira/browse/KAFKA-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2306:
Attachment: KAFKA-2306.patch
New producer should emit metrics for buffer exhaustion
[
https://issues.apache.org/jira/browse/KAFKA-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14606954#comment-14606954
]
Dong Lin commented on KAFKA-2306:
-
Created reviewboard https://reviews.apache.org/r/36034
[
https://issues.apache.org/jira/browse/KAFKA-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2306:
Status: Patch Available (was: Open)
New producer should emit metrics for buffer exhaustion
[
https://issues.apache.org/jira/browse/KAFKA-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-2306:
---
Assignee: Dong Lin
New producer should emit metrics for buffer exhaustion
Dong Lin created KAFKA-2306:
---
Summary: New producer should emit metrics for buffer exhaustion
Key: KAFKA-2306
URL: https://issues.apache.org/jira/browse/KAFKA-2306
Project: Kafka
Issue Type: Bug
method?
Dong Lin wrote:
I have thought about it as well. But probabaly no. Because in
Selector.send() we put failed destinationId is put in failedSends rather than
disconnected. The reason we use failedSends is because send() and poll() in
Selector will be called asynchronously
method?
Dong Lin wrote:
I have thought about it as well. But probabaly no. Because in
Selector.send() we put failed destinationId is put in failedSends rather than
disconnected. The reason we use failedSends is because send() and poll() in
Selector will be called asynchronously
4aee214b24fd990be003adc36d675f015bf22fe6
Diff: https://reviews.apache.org/r/35791/diff/
Testing
---
Thanks,
Dong Lin
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14600047#comment-14600047
]
Dong Lin commented on KAFKA-2298:
-
Updated reviewboard https://reviews.apache.org/r/35791
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2298:
Attachment: KAFKA-2298_2015-06-24_13:00:39.patch
Client Selector can drop connections
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2298:
Labels: (was: quotas)
Client Selector can drop connections on InvalidReceiveException without
Dong Lin created KAFKA-2298:
---
Summary: Client Selector can drop connections on
InvalidReceiveException without notifying NetworkClient
Key: KAFKA-2298
URL: https://issues.apache.org/jira/browse/KAFKA-2298
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2298:
Attachment: KAFKA-2298.patch
Client Selector can drop connections on InvalidReceiveException without
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2298:
Status: Patch Available (was: Open)
Client Selector can drop connections on InvalidReceiveException
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14598024#comment-14598024
]
Dong Lin commented on KAFKA-2298:
-
Created reviewboard https://reviews.apache.org/r/35791
Diff: https://reviews.apache.org/r/35791/diff/
Testing
---
Thanks,
Dong Lin
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/35791/#review89010
---
On June 23, 2015, 5:41 p.m., Dong Lin wrote
method?
Dong Lin wrote:
I have thought about it as well. But probabaly no. Because in
Selector.send() we put failed destinationId is put in failedSends rather than
disconnected. The reason we use failedSends is because send() and poll() in
Selector will be called asynchronously
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2298:
Labels: quotas (was: )
Client Selector can drop connections on InvalidReceiveException without
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14598719#comment-14598719
]
Dong Lin commented on KAFKA-2298:
-
Updated reviewboard https://reviews.apache.org/r/35791
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2298:
Attachment: KAFKA-2298_2015-06-23_18:47:54.patch
Client Selector can drop connections
/Selector.java
4aee214b24fd990be003adc36d675f015bf22fe6
Diff: https://reviews.apache.org/r/35791/diff/
Testing
---
Thanks,
Dong Lin
method?
Dong Lin wrote:
I have thought about it as well. But probabaly no. Because in
Selector.send() we put failed destinationId is put in failedSends rather than
disconnected. The reason we use failedSends is because send() and poll() in
Selector will be called asynchronously
Congrats Guozhang!
Dong
On Tue, Jun 16, 2015 at 9:57 AM, Timothy Chen tnac...@gmail.com wrote:
Congrats Guozhang!!
Tim
On Tue, Jun 16, 2015 at 8:19 AM, Aditya Auradkar
aaurad...@linkedin.com.invalid wrote:
Congrats Guozhang!
From: Ashish
Dong Lin created KAFKA-2278:
---
Summary: JmxTool should support querying all objects when
object-name is omitted
Key: KAFKA-2278
URL: https://issues.apache.org/jira/browse/KAFKA-2278
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2278:
Status: Patch Available (was: Open)
JmxTool should support querying all objects when object-name
[
https://issues.apache.org/jira/browse/KAFKA-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2278:
Attachment: KAFKA-2278.patch
JmxTool should support querying all objects when object-name is omitted
[
https://issues.apache.org/jira/browse/KAFKA-2278?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14588865#comment-14588865
]
Dong Lin commented on KAFKA-2278:
-
Created reviewboard https://reviews.apache.org/r/35540
/
Testing
---
Thanks,
Dong Lin
Dong Lin created KAFKA-2280:
---
Summary: Measurement of bytesInRate and bytesOutRate in
BrokerTopicMetrics should be consistent
Key: KAFKA-2280
URL: https://issues.apache.org/jira/browse/KAFKA-2280
Project
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14584381#comment-14584381
]
Dong Lin commented on KAFKA-2241:
-
[~junrao] No, this bug is fixed in java 1.8.0.
Can you
[
https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2191:
Labels: quotas (was: )
Measured rate should not be infinite
31a2639477bf66f9a05d2b9b07794572d7ec393b
core/src/main/scala/kafka/server/AbstractFetcherThread.scala
83fc47417dd7fe4edf030217fa7fd69d99b170b0
Diff: https://reviews.apache.org/r/34965/diff/
Testing
---
Thanks,
Dong Lin
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14571766#comment-14571766
]
Dong Lin commented on KAFKA-2241:
-
Updated reviewboard https://reviews.apache.org/r/34965
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2241:
Attachment: KAFKA-2241_2015-06-03_15:30:35.patch
AbstractFetcherThread.shutdown() should not block
---
On June 3, 2015, 10:30 p.m., Dong Lin wrote:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34965
/
Testing
---
Thanks,
Dong Lin
[
https://issues.apache.org/jira/browse/KAFKA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2171:
Description:
Initial setup and configuration:
In all scenarios, we create the following entities and topic
[
https://issues.apache.org/jira/browse/KAFKA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2171:
Attachment: KAFKA-2171.patch
System Test for Quotas
--
Key: KAFKA
[
https://issues.apache.org/jira/browse/KAFKA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14571464#comment-14571464
]
Dong Lin commented on KAFKA-2171:
-
Updated reviewboard https://reviews.apache.org/r/34742
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14569988#comment-14569988
]
Dong Lin commented on KAFKA-2241:
-
Oh, I thought the first issue creation has failed
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14570010#comment-14570010
]
Dong Lin commented on KAFKA-2241:
-
Created reviewboard https://reviews.apache.org/r/34965
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2241:
Attachment: KAFKA-2241.patch
AbstractFetcherThread.shutdown() should not block
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2241:
Status: Patch Available (was: Open)
AbstractFetcherThread.shutdown() should not block
/kafka/server/AbstractFetcherThread.scala
83fc47417dd7fe4edf030217fa7fd69d99b170b0
Diff: https://reviews.apache.org/r/34965/diff/
Testing
---
Thanks,
Dong Lin
[
https://issues.apache.org/jira/browse/KAFKA-2240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin resolved KAFKA-2240.
-
Resolution: Duplicate
AbstractFetcherThread.shutdown() should not block on
ReadableByteChannel.read
[
https://issues.apache.org/jira/browse/KAFKA-2240?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin closed KAFKA-2240.
---
Duplicate of KAFKA-2241.
AbstractFetcherThread.shutdown() should not block on
ReadableByteChannel.read(buffer
Dong Lin created KAFKA-2240:
---
Summary: AbstractFetcherThread.shutdown() should not block on
ReadableByteChannel.read(buffer)
Key: KAFKA-2240
URL: https://issues.apache.org/jira/browse/KAFKA-2240
Project
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2241:
Attachment: client.java
server.java
Run server before client. Then check if channel.read
Dong Lin created KAFKA-2241:
---
Summary: AbstractFetcherThread.shutdown() should not block on
ReadableByteChannel.read(buffer)
Key: KAFKA-2241
URL: https://issues.apache.org/jira/browse/KAFKA-2241
Project
On May 28, 2015, 12:58 p.m., Manikumar Reddy O wrote:
core/src/main/scala/kafka/server/ClientQuotaMetrics.scala, line 145
https://reviews.apache.org/r/33049/diff/10/?file=972066#file972066line145
Are we using clientID as uniqueKey?. But as of now, clientID is not
mandatory and it
[
https://issues.apache.org/jira/browse/KAFKA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2171:
Status: Patch Available (was: Open)
System Test for Quotas
--
Key
://reviews.apache.org/r/34170/diff/
Testing
---
Thanks,
Dong Lin
[
https://issues.apache.org/jira/browse/KAFKA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562070#comment-14562070
]
Dong Lin commented on KAFKA-2171:
-
Created reviewboard https://reviews.apache.org/r/34742
[
https://issues.apache.org/jira/browse/KAFKA-2171?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2171:
Description:
Initial setup and configuration:
In all scenarios, we create the following entities and topic
HandlerProcessor in package handler cannot be accessed in package
com.sun.xml.internal.ws.handler
import com.sun.xml.internal.ws.handler.HandlerProcessor.RequestOrResponse
- Dong Lin
On May 26, 2015, 6:53 p.m., Aditya Auradkar wrote
://reviews.apache.org/r/34418/diff/.
Thanks,
Dong Lin
[
https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2191:
Attachment: KAFKA-2191_2015-05-27_17:28:41.patch
Measured rate should not be infinite
[
https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14562074#comment-14562074
]
Dong Lin commented on KAFKA-2191:
-
Updated reviewboard https://reviews.apache.org/r/34170
On May 19, 2015, 5:41 p.m., Dong Lin wrote:
clients/src/main/java/org/apache/kafka/common/metrics/stats/Rate.java, line
64
https://reviews.apache.org/r/34418/diff/1/?file=963982#file963982line64
Hey Jay,
My approach differs with your only in this line
for quota implementation.
- Dong
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34170/#review84341
---
On May 14, 2015, 7:34 a.m., Dong Lin
---
On May 14, 2015, 7:34 a.m., Dong Lin wrote:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34170
with both
approaches.
- Dong Lin
On May 19, 2015, 5:12 p.m., Jay Kreps wrote:
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34418
do we need that? Isn't purging obsolete samples
handled on measurement already? I think that is more elegant. You must see
some issue there, maybe you can explain?
Dong Lin wrote:
Adi: Good catch! I will update the patch to fix the problem.
Jay: Sure. Here is the problem I
On May 12, 2015, 7:38 p.m., Dong Lin wrote:
clients/src/main/java/org/apache/kafka/common/metrics/Sensor.java, lines
122-127
https://reviews.apache.org/r/33049/diff/9/?file=955824#file955824line122
The function quits on the first quota violaation, and calculate
delayTime based
://reviews.apache.org/r/33049/#comment135148
Do you mean RequestKeys.nameForKey(RequestKeys.FetchKey)?
- Dong Lin
On May 11, 2015, 11:17 p.m., Aditya Auradkar wrote:
---
This is an automatically generated e-mail. To reply, visit:
https
do we need that? Isn't purging obsolete samples
handled on measurement already? I think that is more elegant. You must see
some issue there, maybe you can explain?
Dong Lin wrote:
Adi: Good catch! I will update the patch to fix the problem.
Jay: Sure. Here is the problem I
shrinks to zero but why is giving back 0 the right answer? In
the case you guys were testing 0 was safe, but imagine a case where the
monitoring was checking that the value didn't fall below some threshold.
Dong Lin wrote:
The question is, when Rate.measure() is called right after
shrinks to zero but why is giving back 0 the right answer? In
the case you guys were testing 0 was safe, but imagine a case where the
monitoring was checking that the value didn't fall below some threshold.
Dong Lin wrote:
The question is, when Rate.measure() is called right after
?
- Dong
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/34170/#review83687
---
On May 13, 2015, 10:32 p.m., Dong Lin wrote
/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java
b341b7daaa10204906d78b812fb05fd27bc69373
Diff: https://reviews.apache.org/r/34170/diff/
Testing
---
Thanks,
Dong Lin
[
https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14543329#comment-14543329
]
Dong Lin commented on KAFKA-2191:
-
Updated reviewboard https://reviews.apache.org/r/34170
[
https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2191:
Attachment: KAFKA-2191_2015-05-14_00:34:30.patch
Measured rate should not be infinite
/main/java/org/apache/kafka/common/metrics/stats/SampledStat.java
b341b7daaa10204906d78b812fb05fd27bc69373
Diff: https://reviews.apache.org/r/34170/diff/
Testing
---
Thanks,
Dong Lin
. To reply, visit:
https://reviews.apache.org/r/34170/#review83629
---
On May 13, 2015, 3:47 p.m., Dong Lin wrote:
---
This is an automatically generated e-mail. To reply, visit:
https
[
https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2191:
Attachment: KAFKA-2191_2015-05-13_15:32:15.patch
Measured rate should not be infinite
[
https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14542851#comment-14542851
]
Dong Lin commented on KAFKA-2191:
-
Updated reviewboard https://reviews.apache.org/r/34170
[
https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14542135#comment-14542135
]
Dong Lin commented on KAFKA-2191:
-
Created reviewboard https://reviews.apache.org/r/34170
[
https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2191:
Status: Patch Available (was: Open)
Measured rate should not be infinite
[
https://issues.apache.org/jira/browse/KAFKA-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2191:
Attachment: KAFKA-2191.patch
Measured rate should not be infinite
/stats/SampledStat.java
b341b7daaa10204906d78b812fb05fd27bc69373
Diff: https://reviews.apache.org/r/34170/diff/
Testing
---
Thanks,
Dong Lin
Dong Lin created KAFKA-2191:
---
Summary: Measured rate should not be infinite
Key: KAFKA-2191
URL: https://issues.apache.org/jira/browse/KAFKA-2191
Project: Kafka
Issue Type: Bug
://reviews.apache.org/r/33378/#comment134427
Will readFromLocalLog() read data into memory before the cilent's quota is
checked?
- Dong Lin
On May 11, 2015, 9:51 p.m., Aditya Auradkar wrote:
---
This is an automatically generated e-mail
violaation, and calculate delayTime
based on this violation.
Should we enumerate all metric in this.metrics() and set delayTime of the
QuotaViolationException to be the largest delayTime of all violatoins?
- Dong Lin
On May 11, 2015, 11:17 p.m., Aditya Auradkar wrote
/test/scala/unit/kafka/server/OffsetCommitTest.scala
528525b719ec916e16f8b3ae3715bec4b5dcc47d
Diff: https://reviews.apache.org/r/33557/diff/
Testing
---
Thanks,
Dong Lin
[
https://issues.apache.org/jira/browse/KAFKA-1936?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanelfocusedCommentId=14539906#comment-14539906
]
Dong Lin commented on KAFKA-1936:
-
Updated reviewboard https://reviews.apache.org/r/33557
[
https://issues.apache.org/jira/browse/KAFKA-1936?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-1936:
Attachment: KAFKA-1936_2015-05-12_07:32:07.patch
Track offset commit requests separately from produce
---
This is an automatically generated e-mail. To reply, visit:
https://reviews.apache.org/r/33557/#review83234
---
On May 12, 2015, 2:32 p.m., Dong Lin wrote
801 - 900 of 1118 matches
Mail list logo
