Jimmy Wang created KAFKA-18638: ---------------------------------- Summary: Flasky test ClientIdQuotaTest.testThrottledProducerConsumer Key: KAFKA-18638 URL: https://issues.apache.org/jira/browse/KAFKA-18638 Project: Kafka Issue Type: Bug Components: core Affects Versions: 4.0.0 Reporter: Jimmy Wang Assignee: Jimmy Wang Attachments: ScreenShot_20250124154202.PNG
[https://ge.apache.org/scans/tests?search.rootProjectNames=kafka&search.tags=trunk&search.timeZoneId=Asia%2FShanghai&tests.container=kafka.api.ClientIdQuotaTest&tests.sortField=FLAKY&tests.test=testThrottledProducerConsumer(String%2C%20String)%5B2%5D] Also flasky for testQuotaOverrideDelete. This could happen when numRecords is set to 1000. Even if there is no quota validation, the function quotaTestClients.produceUntilThrottled(numRecords) would also return because it has already produced 1000 messages. When numRecords is decreased from 1000 to 500, this case could occur more frequently in my local environment. The value of defaultProducerQuota is 8000 bytes, and the size of each message is about 6 bytes. This means that we should produce at least 160 messages per second to reach the rate limit. I think what we should do to fix it is: 1. Increase the message size. 2. Decrease the defaultProducerQuota. -- This message was sent by Atlassian Jira (v8.20.10#820010)