Details
-
New Feature
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
1.x
-
None
-
Patch
Description
Currently storm kafka client relies on kafka to assign partition to each spout. This may cause unnecessary rebalance in cases where storm itself, e.g. worker restart, slow processing of tuples.