Jun Rao
Jun Rao
Previously, the controller logic wasn't single threaded. So, this check is probably just to prevent concurrent actions. Now that all logic in the controller runs in a single thread, this...
@showuon : I plan to take another look at the PR in the next few days.
One discussion of the PR is around choosing the default value for `compression.level` (https://github.com/apache/kafka/pull/10826#discussion_r917108950). This is tricky since it's specific to the compression type. I am wondering if it's better...
Also, regarding the title of the PR. "Not relaying on metadata to map between topic id and name". We are still relying on the metadata to map topic id and...
@lucasbru : Thanks for the update. As for the integration test failure. I saw the following locally. ``` Formatting metadata directory /var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-13068287464958241505/controller_3000 with metadata.version 4.2-IV1. Formatting metadata directory /var/folders/t1/_lmg790n4dg46yk7lzvzg45r0000gp/T/kafka-13068287464958241505/broker_1_data0 with...
@OmniaGM : Thanks for the updated PR. I ran the new test until failure. After 10 minutes, I still saw the timeout. ``` java.util.concurrent.TimeoutException: testSendWhileTopicGetRecreated() timed out after 120 seconds...
I made the following change and the test hasn't failed after running for 15 minutes. It uses a shorter delivery timeout and request timeout. We probably also want to reduce...
[test_failure.txt](https://github.com/user-attachments/files/21044139/test_failure.txt) @chia7712 : Attached is the test failure output. It still happened after the latest fix.
I ran an existing test `testSendWithTopicReassignmentIsMidWay` until failure and hit the same failure ([test_failure2.txt](https://github.com/user-attachments/files/21062667/test_failure2.txt)). So, this seems to be issue in the test framework on my local environment. We can...
@kevin-wu24 : Could you adjust the title of the PR accordingly? The PR didn't change KafkaMetadataLog#read.