fix commit exceptions (#94) #95

bobh66 · 2021-02-04T15:49:33Z

Note: Before submitting this pull request, please review our contributing
guidelines.

Description

Fixes two problems:

IllegalStateError causes consumer crash when commit is pending and a rebalance happens #94 - fix exceptions on commit when a rebalance occurs during the commit
clean up consumer partition data on partition revoke

…into fix_commit_error

bobh66 added 8 commits February 4, 2021 09:45

fix partition assignment issues (faust-streaming#93) and commit excep…

bc863f9

…tions (faust-streaming#94)

fix partition assignment issues (faust-streaming#93) and commit excep…

ee6cb67

…tions (faust-streaming#94)

Merge branch 'fix_commit_error' of https://github.com/bobh66/faust-1 …

3420f20

…into fix_commit_error

fix black formatting

402008a

fix unused variable in test

949c7f4

fix unit test

584a7fe

fix unused import

0bd2aa5

revert partition assignor changes

827071a

bobh66 changed the title ~~fix partition assignment issues (#93) and commit exceptions (#94)~~ fix commit exceptions (#94) Feb 5, 2021

patkivikram approved these changes Feb 5, 2021

View reviewed changes

patkivikram merged commit 5e799c2 into faust-streaming:master Feb 5, 2021