[
https://issues.apache.org/jira/browse/KAFKA-10548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17388367#comment-17388367
]
Lucas Wang commented on KAFKA-10548:
Hi [~jolshan] thanks for the KIP-516 and for ke
Lucas Wang created KAFKA-13188:
--
Summary: Release the memory back into MemoryPool
Key: KAFKA-13188
URL: https://issues.apache.org/jira/browse/KAFKA-13188
Project: Kafka
Issue Type: Improvement
Lucas Wang created KAFKA-12315:
--
Summary: Clearing the ZkReplicaStateMachine request batch state
upon ControllerMovedException
Key: KAFKA-12315
URL: https://issues.apache.org/jira/browse/KAFKA-12315
Proj
[
https://issues.apache.org/jira/browse/KAFKA-12315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-12315:
---
Description:
As shown in the attached sequence diagram, during topic deletion the following
sequenc
[
https://issues.apache.org/jira/browse/KAFKA-12315?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-12315:
---
Description:
As shown in the attached sequence diagram, during topic deletion the following
sequenc
[
https://issues.apache.org/jira/browse/KAFKA-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang reassigned KAFKA-4453:
-
Assignee: Mayuresh Gharat (was: Lucas Wang)
> add request prioritization
>
[
https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16738587#comment-16738587
]
Lucas Wang commented on KAFKA-7040:
---
Hi [~apovzner], thanks for the info. Please go ahe
[
https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16514422#comment-16514422
]
Lucas Wang commented on KAFKA-7040:
---
Hi [~apovzner]
Thanks for your comment. I didn't
[
https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16520899#comment-16520899
]
Lucas Wang commented on KAFKA-7040:
---
Hi [~apovzner]
Sorry for the delayed response.
Re
Lucas Wang created KAFKA-7162:
-
Summary: Flaky unit tests caused by record creation timestamps
differ from validation time by more than timestampDiffMaxMs
Key: KAFKA-7162
URL: https://issues.apache.org/jira/browse/KAF
[
https://issues.apache.org/jira/browse/KAFKA-7162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang reassigned KAFKA-7162:
-
Assignee: Lucas Wang
> Flaky unit tests caused by record creation timestamps differ from validat
Lucas Wang created KAFKA-7180:
-
Summary: In testHWCheckpointWithFailuresSingleLogSegment, wait
until server1 has joined the ISR before shutting down server2
Key: KAFKA-7180
URL: https://issues.apache.org/jira/browse/K
[
https://issues.apache.org/jira/browse/KAFKA-6974?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang resolved KAFKA-6974.
---
Resolution: Won't Fix
> Changes the interaction between request handler threads and fetcher threads
[
https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6753:
--
Description:
The existing controller code updates metrics after processing every event. This
can slow
[
https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16587994#comment-16587994
]
Lucas Wang commented on KAFKA-6753:
---
Hi [~junrao] thanks reviewing the PR.
Besides the
[
https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16588186#comment-16588186
]
Lucas Wang commented on KAFKA-6753:
---
[~junrao] Personally I'm in favor of removing this
[
https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang reopened KAFKA-6753:
---
> Speed up event processing on the controller
>
>
>
[
https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16590634#comment-16590634
]
Lucas Wang commented on KAFKA-7040:
---
[~lindong] Sure, I will own this ticket and work o
[
https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang reassigned KAFKA-7040:
-
Assignee: Lucas Wang
> The replica fetcher thread may truncate accepted messages during multiple
[
https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang resolved KAFKA-6753.
---
Resolution: Fixed
> Speed up event processing on the controller
> --
[
https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16594328#comment-16594328
]
Lucas Wang commented on KAFKA-6753:
---
[~junrao] Thanks will do.
> Speed up event proce
[
https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6753:
--
Description:
The existing controller code updates metrics after processing every event. This
can slow
Lucas Wang created KAFKA-7350:
-
Summary: Improve or remove the PreferredReplicaImbalanceCount
metric
Key: KAFKA-7350
URL: https://issues.apache.org/jira/browse/KAFKA-7350
Project: Kafka
Issue Ty
[
https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6753:
--
Description:
The existing controller code updates metrics after processing every event. This
can slow
[
https://issues.apache.org/jira/browse/KAFKA-7350?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang reassigned KAFKA-7350:
-
Assignee: Ahmed Al-Mehdi (was: Lucas Wang)
> Improve or remove the PreferredReplicaImbalanceCou
Lucas Wang created KAFKA-6481:
-
Summary: Improving performance of the function
ControllerChannelManager.addUpdateMetadataRequestForBrokers
Key: KAFKA-6481
URL: https://issues.apache.org/jira/browse/KAFKA-6481
[
https://issues.apache.org/jira/browse/KAFKA-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang reassigned KAFKA-6481:
-
Assignee: Lucas Wang
> Improving performance of the function
> ControllerChannelManager.addUpdat
[
https://issues.apache.org/jira/browse/KAFKA-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6481:
--
Description:
The function ControllerChannelManager.addUpdateMetadataRequestForBrokers should
only proce
[
https://issues.apache.org/jira/browse/KAFKA-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6481:
--
Description:
The function ControllerChannelManager.addUpdateMetadataRequestForBrokers should
only proce
[
https://issues.apache.org/jira/browse/KAFKA-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6481:
--
Description:
The function ControllerChannelManager.addUpdateMetadataRequestForBrokers should
only proce
[
https://issues.apache.org/jira/browse/KAFKA-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6481:
--
Description:
The function ControllerChannelManager.addUpdateMetadataRequestForBrokers should
only proce
[
https://issues.apache.org/jira/browse/KAFKA-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6481:
--
Description:
The function ControllerChannelManager.addUpdateMetadataRequestForBrokers should
only proce
[
https://issues.apache.org/jira/browse/KAFKA-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6481:
--
Description:
The function ControllerChannelManager.addUpdateMetadataRequestForBrokers should
only proce
[
https://issues.apache.org/jira/browse/KAFKA-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6481:
--
Description:
The function ControllerChannelManager.addUpdateMetadataRequestForBrokers should
only proce
Lucas Wang created KAFKA-6612:
-
Summary: Added logic to prevent increasing partition counts during
topic deletion
Key: KAFKA-6612
URL: https://issues.apache.org/jira/browse/KAFKA-6612
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang reassigned KAFKA-6612:
-
Assignee: Lucas Wang
> Added logic to prevent increasing partition counts during topic deletion
>
Lucas Wang created KAFKA-6630:
-
Summary: Speed up the processing of StopReplicaResponse events on
the controller
Key: KAFKA-6630
URL: https://issues.apache.org/jira/browse/KAFKA-6630
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-6630?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6630:
--
Summary: Speed up the processing of
TopicDeletionStopReplicaResponseReceived events on the controller (
Lucas Wang created KAFKA-6650:
-
Summary: The controller should be able to handle a partially
deleted topic
Key: KAFKA-6650
URL: https://issues.apache.org/jira/browse/KAFKA-6650
Project: Kafka
Is
Lucas Wang created KAFKA-6652:
-
Summary: The controller should log failed attempts to transition a
replica to OfflineReplica state
Key: KAFKA-6652
URL: https://issues.apache.org/jira/browse/KAFKA-6652
Pro
[
https://issues.apache.org/jira/browse/KAFKA-6652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6652:
--
Summary: The controller should log failed attempts to transition a replica
to OfflineReplica state if th
[
https://issues.apache.org/jira/browse/KAFKA-6652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6652:
--
Description: In certain conditions, the controller's attempt to transition
a replica to OfflineReplica s
[
https://issues.apache.org/jira/browse/KAFKA-6612?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang resolved KAFKA-6612.
---
Resolution: Fixed
> Added logic to prevent increasing partition counts during topic deletion
> ---
[
https://issues.apache.org/jira/browse/KAFKA-6652?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang resolved KAFKA-6652.
---
Resolution: Won't Fix
> The controller should log failed attempts to transition a replica to
> Offlin
Lucas Wang created KAFKA-6753:
-
Summary: Speed up event processing on the controller
Key: KAFKA-6753
URL: https://issues.apache.org/jira/browse/KAFKA-6753
Project: Kafka
Issue Type: Improvement
[
https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6753:
--
Attachment: Screen Shot 2018-04-04 at 7.08.55 PM.png
> Speed up event processing on the controller
> --
[
https://issues.apache.org/jira/browse/KAFKA-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang reassigned KAFKA-4453:
-
Assignee: Lucas Wang (was: Onur Karaman)
> add request prioritization
>
Lucas Wang created KAFKA-6974:
-
Summary: Changes the interaction between request handler threads
and fetcher threads into an ASYNC model
Key: KAFKA-6974
URL: https://issues.apache.org/jira/browse/KAFKA-6974
[
https://issues.apache.org/jira/browse/KAFKA-4453?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-4453:
--
Description:
Today all requests (client requests, broker requests, controller requests) to a
broker ar
Lucas Wang created KAFKA-7040:
-
Summary: The replica fetcher thread may truncate accepted messages
during multiple fast leadership transitions
Key: KAFKA-7040
URL: https://issues.apache.org/jira/browse/KAFKA-7040
[
https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16508867#comment-16508867
]
Lucas Wang commented on KAFKA-7040:
---
[~lindong] Thanks for pointing out the truncation
[
https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16508907#comment-16508907
]
Lucas Wang commented on KAFKA-7040:
---
To be more specific, I think the following sequenc
Lucas Wang created KAFKA-13797:
--
Summary: Adding metric to indicate metadata response outgoing
bytes rate
Key: KAFKA-13797
URL: https://issues.apache.org/jira/browse/KAFKA-13797
Project: Kafka
[
https://issues.apache.org/jira/browse/KAFKA-13797?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-13797:
---
Description:
It's not a common case, but we experienced the following problem in one of our
cluster
Lucas Wang created KAFKA-13815:
--
Summary: Avoid reinitialization for a replica that is being deleted
Key: KAFKA-13815
URL: https://issues.apache.org/jira/browse/KAFKA-13815
Project: Kafka
Issue
[
https://issues.apache.org/jira/browse/KAFKA-13815?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang reassigned KAFKA-13815:
--
Assignee: Lucas Wang
> Avoid reinitialization for a replica that is being deleted
> -
Lucas Wang created KAFKA-14381:
--
Summary: Support listing all partitions being reassigned in a
cluster
Key: KAFKA-14381
URL: https://issues.apache.org/jira/browse/KAFKA-14381
Project: Kafka
Iss
[
https://issues.apache.org/jira/browse/KAFKA-14381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang reassigned KAFKA-14381:
--
Assignee: Lucas Wang
> Support listing all partitions being reassigned in a cluster
> ---
Lucas Wang created KAFKA-14424:
--
Summary: Cancellation of an ongoing replica reassignment should
have sanity checks
Key: KAFKA-14424
URL: https://issues.apache.org/jira/browse/KAFKA-14424
Project: Kafka
Lucas Wang created KAFKA-14213:
--
Summary: Reduce lock contention between
control-plane-kafka-request-handler and kafka-log-cleaner-thread
Key: KAFKA-14213
URL: https://issues.apache.org/jira/browse/KAFKA-14213
[
https://issues.apache.org/jira/browse/KAFKA-14213?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-14213:
---
Description:
We found that the StopReplica request's local processing time may be quite long
due to
Lucas Wang created KAFKA-10734:
--
Summary: Speedup the processing of LeaderAndIsr request
Key: KAFKA-10734
URL: https://issues.apache.org/jira/browse/KAFKA-10734
Project: Kafka
Issue Type: Improv
[
https://issues.apache.org/jira/browse/KAFKA-10734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235061#comment-17235061
]
Lucas Wang commented on KAFKA-10734:
Thanks for your reply [~junrao]. In some cluste
Lucas Wang created KAFKA-10751:
--
Summary: Generate log to help estimate messages lost during ULE
Key: KAFKA-10751
URL: https://issues.apache.org/jira/browse/KAFKA-10751
Project: Kafka
Issue Type
[
https://issues.apache.org/jira/browse/KAFKA-10751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17235702#comment-17235702
]
Lucas Wang commented on KAFKA-10751:
PR submitted: https://github.com/apache/kafka/p
65 matches
Mail list logo