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
Closing consumer takes 10 second #661
Comments
@jliunyu Can you take a look at this? Haven't checked the code, but make sure Close() isn't waiting for a rebalance event if application.rebalance is not enabled. |
Hi @edenhill, after checking the code, found that Close() is always waiting for rebalance event with the following code: I will take a look how to fix it and provide a fix soon. |
same problem |
I've seen this too. Consumer always takes at least the value of |
Hello, this issue seems frozen. I had to downgrade to v1.5.2 to overcome this issue until further update. @edenhill, @jliunyu I have a question the code pointer that causes the delay: https://github.com/confluentinc/confluent-kafka-go/blob/master/kafka/consumer.go#L438 Additionally, this issue seems relevant to another issue: #610 confluent-kafka-go version: 1.7.0 I would be happy to help on the resolution of this issue. |
Same issue here. Even with poll set to 100 it takes > 5-10 seconds to Close the consumer for me |
The fix for this is planned for the next release |
@jliunyu any update on this? When's the next release due? |
This is the PR for the fix: #757 |
Closing this as the PR above is merged. |
Description
I am trying to just open and close consumer. Closing takes 10 seconds.
I found on consumer code:
Are there any parameters to force consumer fast close?
Please advise;
How to reproduce
output:
consumer closed. closing time: 10.005907343s
Checklist
Please provide the following information:
1.7.0
):2.7.0
&kafka.ConfigMap{"bootstrap.servers": "localhost:9092","group.id": "group","broker.address.family": "v4",}
"debug": ".."
as necessary)The text was updated successfully, but these errors were encountered: