Skip to content
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

Reader block indefinitely during kafka deployment #1044

Open
OlivierCazade opened this issue Nov 30, 2022 · 1 comment
Open

Reader block indefinitely during kafka deployment #1044

OlivierCazade opened this issue Nov 30, 2022 · 1 comment
Assignees
Labels

Comments

@OlivierCazade
Copy link

Describe the bug

If a reader is started before any kafka deployment, whend kafka is finally deployed, the reader block and the ReadMessage function block.

Kafka Version

  • What version(s) of Kafka are you testing against?

3.2 deployed using strimzi operator in a kubernetes environment.

  • What version of kafka-go are you using?

Could reproduce it with 0.4.35 and 0.4.38

Expected Behavior

The ReadMessage should either return an error or the next message but not block indefinitely

Observed Behavior

In a loop constantly reading message from a kafka cluster. If the kafka cluster was not deployed and is deployed after the loop was started, the ReadMessage start to block. The blocking happen at the same time the kafka cluster was deployed. The readMessage was successfully returning an error when kafka was not deployed.

Additional Context

I can not provide debug logs because I could not reproduce the bug with a loglevel set to debug. It looks like some race condition and setting loglevel to debug prevent it to happens in some way.

@nlsun
Copy link
Contributor

nlsun commented Feb 3, 2023

Hi @OlivierCazade can you confirm how long you waited before determining that it was blocking indefinitely? Is it longer than the ReadTimeout? Was kafka rebalancing?

Debug logs would be helpful, it would also be helpful to have a reliable way to reproduce the issue in order to fix it.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
Projects
None yet
Development

No branches or pull requests

2 participants