aoli-al commented on PR #16941: URL: https://github.com/apache/kafka/pull/16941#issuecomment-2306057184
Thanks for the PR fixing the flaky test. I'm wondering if the `currentTask` method should be redesigned. Interleaving it with other methods causes at least two test failures. The root cause is that `currentTask` is not thread-safe and may return a stale/intermediate value. I'm not entirely sure how this method will be used. From the docs, it seems that client code can invoke it since it is a public method declared in the interface. -- 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