if the consumer rebalance isn't fast enough, it might lead to race conditions where the producers would send the requests and they won't be matched against the received responses. That's true especially for consumer offset : latest.
We might need a semaphore from the consumer threads on first successful poll and a before block for every simulation with the consumer offset set to latest
Version 0.9.1-beta
if the consumer rebalance isn't fast enough, it might lead to race conditions where the producers would send the requests and they won't be matched against the received responses. That's true especially for consumer offset : latest.
We might need a semaphore from the consumer threads on first successful poll and a before block for every simulation with the consumer offset set to latest
Version 0.9.1-beta