Lucas Wang
Lucas Wang
## Experience Report Note: Feature requests are judged based on user experience and modeled on [Go Experience Reports](https://github.com/golang/go/wiki/ExperienceReports). These reports should focus on the problems: they should not focus on...
This PR resolves #1890.
An example of the current state output is `ExecutorState: {state: INTER_BROKER_REPLICA_MOVEMENT_TASK_IN_PROGRESS, pending/in-progress/aborting/finished/total inter-broker partition movement 268569/48/0/7512/276129, completed/total bytes(MB): 3803670/195202695, maximum concurrent inter-broker partition movements per-broker: 2, triggeredUserTaskId: fded915c-6341-4c56-863f-04bb90051207, triggeredTaskReason: luwang...
This PR includes the following changes 1. Adding the type field to the LeaderAndIsr request as proposed in KIP-516 2. Letting the controller set the type of LeaderAndIsr requests to...
During the replica movement, the current output shows the total bytes and finished bytes during the replica movement. It'll be useful to also provide an ETA.
As shown in the conversations https://linkedin-randd.slack.com/archives/C04FMP0HB17/p1671222219329569, if a new monitoring topic is just created in a cluster, the AdminClient.describeTopic API could result in UnknownTopicOrPartitionExceptions, which causes the whole process to...
TICKET = N/A LI_DESCRIPTION = Exclude logback as a dependency as the assumption is that log4j will be used. Tested the change with a info level logging in one of...
TICKET = N/A LI_DESCRIPTION = Add comment to explain the safety of the brokerEpochSupplier method EXIT_CRITERIA = N/A *More detailed description of your change, if necessary. The PR title and...
If we expand partitions using the AdminZkClient, currently there is no logic to avoid assigning replicas to preferred controllers. This PR fixes the issue in the following two places: 1....