apoorvmittal10 opened a new pull request, #19918: URL: https://github.com/apache/kafka/pull/19918
The PR: https://github.com/apache/kafka/pull/17636 migrated DelayedOperationPurgatory from scala to java, and instatiated `expirationReaper` at instance level where `purgatoryName` is still `null` hence all expiration threads from different Purgatories has incorrect names. <img width="216" alt="Screenshot 2025-06-07 at 01 28 58" src="https://github.com/user-attachments/assets/fd1b8137-b290-42e0-9a95-258fde5737d2"; /> The PR fixes the instatiation of ExpirationReaper, in constructor when `purgatoryName` is defined. <img width="296" alt="Screenshot 2025-06-07 at 01 31 27" src="https://github.com/user-attachments/assets/9912311b-ddf6-4554-8e04-d0b8ad208abc"; /> This issue affects 4.0 version as well, though minor. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
