Skip to content

KAFKA-17840: Move ReplicationQuotaManager to server module#21702

Open
mimaison wants to merge 2 commits intoapache:trunkfrom
mimaison:kafka-17840
Open

KAFKA-17840: Move ReplicationQuotaManager to server module#21702
mimaison wants to merge 2 commits intoapache:trunkfrom
mimaison:kafka-17840

Conversation

@mimaison
Copy link
Member

@mimaison mimaison commented Mar 10, 2026

Move ReplicationQuotaManager, ReplicaQuota and
ReplicationQuotaManagerTest.

@github-actions github-actions bot added core Kafka Broker performance KIP-932 Queues for Kafka labels Mar 10, 2026
Copy link
Contributor

@UladzislauBlok UladzislauBlok left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

//Sleep for 2 more window
time.sleep(2 * 1000); //so now at 3.5s
assertFalse(quota.isQuotaExceeded());
assertEquals(251d / 4.5, rate(metrics), 0);
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
assertEquals(251d / 4.5, rate(metrics), 0);
assertEquals(251 / 4.5, rate(metrics), 0);

assertEquals(251d / 4.5, rate(metrics), 0);
}

double rate(Metrics metrics) {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Suggested change
double rate(Metrics metrics) {
private double rate(Metrics metrics) {

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

core Kafka Broker KIP-932 Queues for Kafka performance

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants