Dong Lin created KAFKA-4841:
---
Summary: NetworkClient should only consider a connection to be
fail after attempt to connct
Key: KAFKA-4841
URL: https://issues.apache.org/jira/browse/KAFKA-4841
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-4841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-4841:
Summary: NetworkClient should only consider a connection to be fail after
attempt to connect (was: NetworkC
[
https://issues.apache.org/jira/browse/KAFKA-4841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-4841:
Description:
KAFKA-4820 allows new request to be enqueued to unsent by user thread while
some other thread
[
https://issues.apache.org/jira/browse/KAFKA-4841?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-4841:
Description:
KAFKA-4820 allows new request to be enqueued to unsent by user thread while
some other thread
Dong Lin created KAFKA-4962:
---
Summary: Unify the way of implementing schemas in Protocol.java
Key: KAFKA-4962
URL: https://issues.apache.org/jira/browse/KAFKA-4962
Project: Kafka
Issue Type: Improv
[
https://issues.apache.org/jira/browse/KAFKA-4962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-4962:
Summary: Unify the implentation of schemas in Protocol.java (was: Unify
the way of implementing schemas in
[
https://issues.apache.org/jira/browse/KAFKA-4962?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-4962:
Description:
The schemas implementation in Protocol.java is currently inconsistent. For
example, the implem
[
https://issues.apache.org/jira/browse/KAFKA-4973?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15947479#comment-15947479
]
Dong Lin commented on KAFKA-4973:
-
[~ijuma] Certainly. Thanks for filing the ticket. I wil
[
https://issues.apache.org/jira/browse/KAFKA-3042?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15959741#comment-15959741
]
Dong Lin commented on KAFKA-3042:
-
[~pengwei] Sorry, I didn't notice your message in Jan u
[
https://issues.apache.org/jira/browse/KAFKA-5075?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-5075:
Summary: Defer exception to the next pollOnce() if consumer's fetch
position has already increased (was: Th
Dong Lin created KAFKA-5078:
---
Summary: PartitionRecords.fetchRecords(...) should defer exception
to the next call if iterator has already moved across any valid record
Key: KAFKA-5078
URL: https://issues.apache.org/jira
[
https://issues.apache.org/jira/browse/KAFKA-5078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-5078:
Description:
Suppose there are two valid records followed by one invalid records in the
FetchResponse.Parti
[
https://issues.apache.org/jira/browse/KAFKA-5078?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-5078:
Description:
Suppose there are two valid records followed by one invalid records in the
FetchResponse.Parti
Dong Lin created KAFKA-5086:
---
Summary: Topic expiry time in Metadata should be updated every
time the topic metadata is requested
Key: KAFKA-5086
URL: https://issues.apache.org/jira/browse/KAFKA-5086
Projec
[
https://issues.apache.org/jira/browse/KAFKA-5086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-5086:
Summary: Update topic expiry time in Metadata every time the topic metadata
is requested (was: Topic expiry
Dong Lin created KAFKA-4735:
---
Summary: Fix deadlock issue during MM shutdown
Key: KAFKA-4735
URL: https://issues.apache.org/jira/browse/KAFKA-4735
Project: Kafka
Issue Type: Bug
Reporte
Dong Lin created KAFKA-4763:
---
Summary: Handle disk failure for JBOD (KIP-112)
Key: KAFKA-4763
URL: https://issues.apache.org/jira/browse/KAFKA-4763
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-3473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-3473:
---
Assignee: Dong Lin
> Add controller channel manager request queue time metric.
>
[
https://issues.apache.org/jira/browse/KAFKA-3294?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15262592#comment-15262592
]
Dong Lin commented on KAFKA-3294:
-
[~harsha_ch] [~parth.brahmbhatt] This seems to be a big
Dong Lin created KAFKA-3655:
---
Summary: awaitFlushCompletion() in RecordAccumulator should
always decrement flushesInProgress count.
Key: KAFKA-3655
URL: https://issues.apache.org/jira/browse/KAFKA-3655
Pro
[
https://issues.apache.org/jira/browse/KAFKA-3655?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-3655:
Assignee: chen zhu (was: Dong Lin)
> awaitFlushCompletion() in RecordAccumulator should always decrement
[
https://issues.apache.org/jira/browse/KAFKA-3003?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15061582#comment-15061582
]
Dong Lin commented on KAFKA-3003:
-
Great catch!
> The fetch.wait.max.ms is not honored wh
[
https://issues.apache.org/jira/browse/KAFKA-3025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15068553#comment-15068553
]
Dong Lin commented on KAFKA-3025:
-
[~apovzner], please don't create the ticket and assign
[
https://issues.apache.org/jira/browse/KAFKA-3025?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15068603#comment-15068603
]
Dong Lin commented on KAFKA-3025:
-
[~apovzner] Cool. Thanks for the update.
> KIP-32 (par
[
https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-3052:
---
Assignee: Dong Lin
> broker properties get logged twice if acl is enabled
> -
[
https://issues.apache.org/jira/browse/KAFKA-3052?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-3052:
Assignee: (was: Dong Lin)
> broker properties get logged twice if acl is enabled
> -
[
https://issues.apache.org/jira/browse/KAFKA-3045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-3045:
---
Assignee: Dong Lin
> ZkNodeChangeNotificationListener shouldn't log interrupted exception as error
>
[
https://issues.apache.org/jira/browse/KAFKA-3064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15082367#comment-15082367
]
Dong Lin commented on KAFKA-3064:
-
[~Skandragon], can you clarify why consumer would throw
[
https://issues.apache.org/jira/browse/KAFKA-3064?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15082367#comment-15082367
]
Dong Lin edited comment on KAFKA-3064 at 1/5/16 4:44 AM:
-
[~Skandr
Dong Lin created KAFKA-3089:
---
Summary: VerifiableProducer should do a clean shutdown in
stop_node()
Key: KAFKA-3089
URL: https://issues.apache.org/jira/browse/KAFKA-3089
Project: Kafka
Issue Type:
[
https://issues.apache.org/jira/browse/KAFKA-3111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-3111:
---
Assignee: Dong Lin
> java.lang.ArithmeticException: / by zero in ConsumerPerformance
> --
[
https://issues.apache.org/jira/browse/KAFKA-3111?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-3111:
Assignee: (was: Dong Lin)
> java.lang.ArithmeticException: / by zero in ConsumerPerformance
> --
[
https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-3145:
Assignee: Dong Lin
> CPU Usage Spike to 100% when network connection is to error port
>
[
https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147899#comment-15147899
]
Dong Lin commented on KAFKA-3145:
-
[~zhiwei], I am not able to reproduce the problem. I st
[
https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147932#comment-15147932
]
Dong Lin commented on KAFKA-3145:
-
[~zhiwei], yeah I understand that CPU usage depends the
[
https://issues.apache.org/jira/browse/KAFKA-3145?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15147971#comment-15147971
]
Dong Lin commented on KAFKA-3145:
-
[~zhiwei] Can you want to try to reproduce it using tru
[
https://issues.apache.org/jira/browse/KAFKA-3257?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-3257:
Assignee: chen zhu
> bootstrap-test-env.sh version check fails when grep has --colour option
> enabled.
> -
Dong Lin created KAFKA-3330:
---
Summary: Decrease log cleaner offset checkpoint if the log is
truncated
Key: KAFKA-3330
URL: https://issues.apache.org/jira/browse/KAFKA-3330
Project: Kafka
Issue Typ
[
https://issues.apache.org/jira/browse/KAFKA-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-3330:
Description:
Were getting a number of failures of the log compaction thread with the
following error:
2016/0
[
https://issues.apache.org/jira/browse/KAFKA-3330?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-3330:
Summary: Truncate log cleaner offset checkpoint if the log is truncated
(was: Decrease log cleaner offset c
[
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
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14584381#comment-14584381
]
Dong Lin commented on KAFKA-2241:
-
[~junrao] No, this bug is fixed in java 1.8.0.
Can you
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:comment-tabpanel&focusedCommentId=14588865#comment-14588865
]
Dong Lin commented on KAFKA-2278:
-
Created reviewboard https://reviews.apache.org/r/35540/
[
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:all-tabpanel
]
Dong Lin updated KAFKA-2278:
Status: Patch Available (was: Open)
> JmxTool should support querying all objects when object-name is omitt
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: K
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
P
[
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
> no
[
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 witho
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14598024#comment-14598024
]
Dong Lin commented on KAFKA-2298:
-
Created 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:
Labels: (was: quotas)
> Client Selector can drop connections on InvalidReceiveException without
> notifyi
[
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
> notifyi
[
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 on InvalidReceiveExc
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-24_13:00:39.patch
> Client Selector can drop connections on InvalidReceiveExc
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14600047#comment-14600047
]
Dong Lin commented on KAFKA-2298:
-
Updated reviewboard https://reviews.apache.org/r/35791/
[
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
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
[
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
> ---
[
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-tabpanel&focusedCommentId=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-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=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-tabpanel&focusedCommentId=14615627#comment-14615627
]
Dong Lin commented on KAFKA-2241:
-
Hi [~junrao]], could you please review this patch when
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14615627#comment-14615627
]
Dong Lin edited comment on KAFKA-2241 at 7/6/15 8:48 PM:
-
Hi [~jun
[
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-tabpanel&focusedCommentId=14615736#comment-14615736
]
Dong Lin commented on KAFKA-2306:
-
Updated 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:
Attachment: KAFKA-2306_2015-07-06_18:21:43.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-tabpanel&focusedCommentId=14616028#comment-14616028
]
Dong Lin commented on KAFKA-2306:
-
Updated reviewboard https://reviews.apache.org/r/36034/
[
https://issues.apache.org/jira/browse/KAFKA-2306?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14617057#comment-14617057
]
Dong Lin commented on KAFKA-2306:
-
Updated 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:
Attachment: KAFKA-2306_2015-07-07_10:47:10.patch
> New producer should emit metrics for buffer exhaustion
>
[
https://issues.apache.org/jira/browse/KAFKA-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14619059#comment-14619059
]
Dong Lin commented on KAFKA-2298:
-
[~sriharsha] Sorry for the inconvenience. But the patch
[
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-07-09_15:35:49.patch
> AbstractFetcherThread.shutdown() should not block on
> R
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14621396#comment-14621396
]
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:
Status: Patch Available (was: In Progress)
> AbstractFetcherThread.shutdown() should not block on
> Readab
[
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-07-13_13:30:07.patch
> AbstractFetcherThread.shutdown() should not block on
> R
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625284#comment-14625284
]
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-07-13_14:51:42.patch
> AbstractFetcherThread.shutdown() should not block on
> R
[
https://issues.apache.org/jira/browse/KAFKA-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14625428#comment-14625428
]
Dong Lin commented on KAFKA-2241:
-
Updated reviewboard https://reviews.apache.org/r/34965/
[
https://issues.apache.org/jira/browse/KAFKA-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Work on KAFKA-2332 started by Dong Lin.
---
> Add quota metrics to old producer and consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2332:
Attachment: KAFKA-2332.patch
> Add quota metrics to old producer and consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2332:
Status: Patch Available (was: In Progress)
> Add quota metrics to old producer and consumer
> -
[
https://issues.apache.org/jira/browse/KAFKA-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2332:
Attachment: KAFKA-2332.patch
> Add quota metrics to old producer and consumer
>
[
https://issues.apache.org/jira/browse/KAFKA-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14638348#comment-14638348
]
Dong Lin commented on KAFKA-2332:
-
Created reviewboard https://reviews.apache.org/r/36722/
[
https://issues.apache.org/jira/browse/KAFKA-2332?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14639113#comment-14639113
]
Dong Lin commented on KAFKA-2332:
-
[~ijuma] I think the intent is to support existing cons
[
https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-2066:
---
Assignee: Dong Lin
> Replace FetchRequest / FetchResponse with their
> org.apache.kafka.common.reque
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14639457#comment-14639457
]
Dong Lin commented on KAFKA-1690:
-
[~harsha_ch] Thanks for the patch. I would like to test
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14639477#comment-14639477
]
Dong Lin commented on KAFKA-1690:
-
[~harsha_ch] Cool. It will great if the patch can be av
[
https://issues.apache.org/jira/browse/KAFKA-2066?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2066:
Assignee: (was: Dong Lin)
> Replace FetchRequest / FetchResponse with their
> org.apache.kafka.common.r
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14641327#comment-14641327
]
Dong Lin commented on KAFKA-1690:
-
[~stp_abhi] Is the patch available for test? It will be
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14641327#comment-14641327
]
Dong Lin edited comment on KAFKA-1690 at 7/25/15 6:18 AM:
--
Is the
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14641417#comment-14641417
]
Dong Lin commented on KAFKA-1690:
-
[~harsha_ch] Thanks so much! Sure, I will let you know
[
https://issues.apache.org/jira/browse/KAFKA-1690?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14642237#comment-14642237
]
Dong Lin commented on KAFKA-1690:
-
[~harsha_ch] Thanks much for letting us know.
> new ja
[
https://issues.apache.org/jira/browse/KAFKA-2387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-2387:
---
Assignee: Dong Lin
> Improve KafkaConsumer API
> -
>
> Key: K
[
https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-2388:
---
Assignee: Dong Lin
> subscribe(topic)/unsubscribe(topic) should either take a callback to allow
> us
[
https://issues.apache.org/jira/browse/KAFKA-2390?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin reassigned KAFKA-2390:
---
Assignee: Dong Lin
> Seek() should take a callback.
> --
>
>
[
https://issues.apache.org/jira/browse/KAFKA-2387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2387:
Assignee: (was: Dong Lin)
> Improve KafkaConsumer API
> -
>
> Ke
[
https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2388:
Assignee: Jiangjie Qin (was: Dong Lin)
> subscribe(topic)/unsubscribe(topic) should either take a callback
[
https://issues.apache.org/jira/browse/KAFKA-2388?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dong Lin updated KAFKA-2388:
Assignee: Onur Karaman (was: Jiangjie Qin)
> subscribe(topic)/unsubscribe(topic) should either take a callb
201 - 300 of 514 matches
Mail list logo
