Replies: 1 comment 1 reply
-
|
Hi @mashkovd, I'm also running into this error. I tried putting the Have you had any negative experiences otherwise? Would you consider submitting a pull with the fix? It does work for me. |
Beta Was this translation helpful? Give feedback.
1 reply
-
|
Looks like #1014 will fix this. |
Beta Was this translation helpful? Give feedback.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
-
Hello,
I've identified an issue related to Kafka unavailability, where the library logs numerous messages with the text "Unable to connect to node with id %s: %s." To address this, I'm considering creating a pull request. However, I want to ensure that I'm not overlooking any crucial details.
In this section, the code uses
await asyncio.sleep(self._retry_backoff)to introduce a delay, and the retry interval is controlled by the retry_backoff_ms parameter.I propose incorporating a similar approach in this section. Does this seem like the right solution to you?
Beta Was this translation helpful? Give feedback.
All reactions