-
Notifications
You must be signed in to change notification settings - Fork 3.6k
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
Add client-side lookup throttling #182
Conversation
} | ||
|
||
/** | ||
* Configure total allowed concurrent lookup-request to prevent overload on broker. |
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.
We should note here in the javadoc that the default is 5000 and that one should not worry to change this unless you plan to produce/subscribe on 1000s of topics from the same client instance.
} | ||
}); | ||
} else { | ||
log.warn("{} Failed to add lookup-request into pending queue", requestId); |
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.
I'd rather keep this at debug level, since it is part of the normal operations flow
31602c3
to
3e40832
Compare
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.
👍
(Let's wait to tag 1.16 release before merging this one)
Signed-off-by: xiaolong.ran <[email protected]> Fix nil pointer dereference of PartitionMetadataResponse
fix apache#181 This pull request fix the deadlock in kop.
Motivation
Sometimes, It is useful to throttle at client in order to avoid large number of concurrent lookup-requests going to broker while creating producers/consumers.
Modifications
Add client side lookup throttling while creating producer and consumer.
Result
Client can have capability to restrict number of concurrent lookup request to broker in order to throttle while creating producer/consumer.