-
Notifications
You must be signed in to change notification settings - Fork 183
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
IllegalStateException on seek to offset of a partition that was removed by a rebalance #54
Closed
1 of 2 tasks
Comments
Receiving the same message above plus the following exception:
|
@patkivikram I believe this issue has been resolved as of the 0.3.2 beta versions |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Checklist
master
branch of Faust.Steps to reproduce
faust-streaming 0.3.0
aiokafka 0.7.0
In this example, partitions 1, 5 and 10 were originally assigned but after the rebalance partition 1 is no longer assigned. The code tries to seek to the committed offset for partition 1 and crashes:
Expected behavior
Should not attempt to seek on a partition that has been removed. Maybe catch the exception and restart the fetcher?
Actual behavior
Process crashes on exception
Full traceback
Versions
The text was updated successfully, but these errors were encountered: