-
Notifications
You must be signed in to change notification settings - Fork 13.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
KAFKA-7939: Fix timing issue in KafkaAdminClientTest.testCreateTopicsRetryBackoff #6418
Conversation
There is a small timing window where |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@omkreddy Thanks for the PR. Left one minor comment, apart from that LGTM.
@@ -1261,6 +1261,11 @@ private static boolean groupIdIsUnrepresentable(String groupId) { | |||
return groupId == null; | |||
} | |||
|
|||
//for testing | |||
int noOfPendingCalls() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Perhaps numPendingCalls
is easier to read?
@rajinisivaram Thanks for the review. |
…RetryBackoff There is a small timing window where ```time.sleep(retryBackoff)``` will get executed before adminClient adds retry request to the queue. Added a check to wait until the retry call added to the queue in AdminClient. Author: Manikumar Reddy <manikumar.reddy@gmail.com> Reviewers: Rajini Sivaram <rajinisivaram@googlemail.com> Closes #6418 from omkreddy/KAFKA-7939 (cherry picked from commit 173a7e3) Signed-off-by: Manikumar Reddy <manikumar@confluent.io>
…RetryBackoff There is a small timing window where ```time.sleep(retryBackoff)``` will get executed before adminClient adds retry request to the queue. Added a check to wait until the retry call added to the queue in AdminClient. Author: Manikumar Reddy <manikumar.reddy@gmail.com> Reviewers: Rajini Sivaram <rajinisivaram@googlemail.com> Closes apache#6418 from omkreddy/KAFKA-7939
There is a small timing window where
time.sleep(retryBackoff)
will get executed before adminClient adds retry request to the queue. Added a check to wait until the retry call added to the queue in AdminClient.Committer Checklist (excluded from commit message)