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
[
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-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
[
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
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-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-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-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
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
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
[
https://issues.apache.org/jira/browse/KAFKA-10548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17388367#comment-17388367
]
Lucas Wang commented on KAFKA-10548:
Hi [~jolshan] thanks for the KIP-516 and for keeping track of
[
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
[
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
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
[
https://issues.apache.org/jira/browse/KAFKA-10751?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235702#comment-17235702
]
Lucas Wang commented on KAFKA-10751:
PR submitted: https://github.com/apache/kafka/pull/9533
>
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
[
https://issues.apache.org/jira/browse/KAFKA-10734?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17235061#comment-17235061
]
Lucas Wang commented on KAFKA-10734:
Thanks for your reply [~junrao]. In some clusters, our SREs set
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:
[
https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16738587#comment-16738587
]
Lucas Wang commented on KAFKA-7040:
---
Hi [~apovzner], thanks for the info. Please go ahead and take over
[
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-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
[
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
[
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: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=16594328#comment-16594328
]
Lucas Wang commented on KAFKA-6753:
---
[~junrao] Thanks will do.
> Speed up event processing on the
[
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
[
https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16590634#comment-16590634
]
Lucas Wang commented on KAFKA-7040:
---
[~lindong] Sure, I will own this ticket and work on the fix.
>
[
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-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16588186#comment-16588186
]
Lucas Wang commented on KAFKA-6753:
---
[~junrao] Personally I'm in favor of removing this metric compared
[
https://issues.apache.org/jira/browse/KAFKA-6753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=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: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-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
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/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
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/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16520899#comment-16520899
]
Lucas Wang commented on KAFKA-7040:
---
Hi [~apovzner]
Sorry for the delayed response.
Regarding Case 1
[
https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508907#comment-16508907
]
Lucas Wang commented on KAFKA-7040:
---
To be more specific, I think the following sequence of events may
[
https://issues.apache.org/jira/browse/KAFKA-7040?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16508867#comment-16508867
]
Lucas Wang commented on KAFKA-7040:
---
[~lindong] Thanks for pointing out the truncation may happen below
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-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
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 reassigned KAFKA-4453:
-
Assignee: Lucas Wang (was: Onur Karaman)
> add request prioritization
>
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-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
>
[
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 updated KAFKA-6652:
--
Description: In certain conditions, the controller's attempt to transition
a replica to OfflineReplica
[
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
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
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
[
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-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-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-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-6481?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Lucas Wang updated KAFKA-6481:
--
Description:
The function ControllerChannelManager.addUpdateMetadataRequestForBrokers should
only
[
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
[
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
[
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
[
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
[
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
[
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
>
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
63 matches
Mail list logo
