-
Couldn't load subscription status.
- Fork 407
Closed
Labels
Description
This is just FYI since I don't think it's a bug in librdkafka, not here. When I create many processes with consumers that belong to the same consumer group, sometimes I get librdkafka assert on partition assignment: confluentinc/librdkafka#761 For now I've solved the problem by commenting out the code that sets up the rebalance_cb as it seem to fix that and use my own fork, but it would be nice to understand it better and fix. No particular steps to reproduce as well as no small test case unfortunately.