Skip to content
New issue

Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? # to your account

Unneeded connections to unavailable brokers #4881

Open
4 of 7 tasks
emasab opened this issue Oct 22, 2024 · 0 comments
Open
4 of 7 tasks

Unneeded connections to unavailable brokers #4881

emasab opened this issue Oct 22, 2024 · 0 comments

Comments

@emasab
Copy link
Contributor

emasab commented Oct 22, 2024

Description

What happens:
Connection is tried to brokers not reported in Metadata response, leading to timeouts that can vary depending if broker DNS entry has been removed (quicker), or DNS is available but there's no route to host (slower), or broker is reachable but port isn't bound (quicker).
Failed connection to these removed brokers can continue until client is restarted.

Conditions:
When scaling down a cluster, or just during a cluster roll, in case there aren't available connections already, the least used broker is selected and, in that case, one of the brokers removed from the cluster temporarily or permanently (client cannot know) can be used.

How to reproduce

TBW

Checklist

Please provide the following information:

  • librdkafka version (release number or git tag): any
  • Apache Kafka version: any
  • librdkafka client configuration: any
  • Operating system: any
  • Provide logs (with debug=.. as necessary) from librdkafka
  • Provide broker log excerpts
  • Critical issue: it can be critical depending on the duration of the timeout, otherwise client recovers but it causes increased latency
@emasab emasab changed the title Unneeded connections to available brokers Unneeded connections to unavailable brokers Oct 22, 2024
# for free to join this conversation on GitHub. Already have an account? # to comment
Labels
None yet
Projects
None yet
Development

No branches or pull requests

1 participant