-
-
Notifications
You must be signed in to change notification settings - Fork 526
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
#1147 Allow disconnect on rebalance, currently if trying to rebalance kafka… #1462
base: master
Are you sure you want to change the base?
#1147 Allow disconnect on rebalance, currently if trying to rebalance kafka… #1462
Conversation
… will not disconnect properly if disconnect is called.
…emains consistent
… if allowRecconectAfterRebalance is set to false, the consumer wont try to reconnect. Also update the typescript definition
…ustralia/kafkajs into HLCLOUD-682-disconnect-on-rebalance
@tulios @Nevon It does not change the default or affect any of the default behaviour that kafkajs provides it should not cause any problems to existing code. Given the way the unit tests are structured, I am unsure about the way to engineer a unit test. Any recommendations would be appreciated. typescript definitions are updated. Please give me advice on how to get this pull request accepted. Thanks in advance for your time. |
updated version of tulios#1148 and tulios#1462
Trying to fix the bug where if we call disconnect on kafka consumer and a rebalance is in process then the disconnect does not work.
#1147