Dana Powers
Dana Powers
Deleting from pypi would likely cause builds, like yours, to break unceremoniously. I'm not that mean :) Instead we are simply not updating it, and letting your confusion lead to...
were you testing against master or the 1.2 release ? if master (or v1.3), the call would probably block on getConnection. see https://github.com/fiorix/txredisapi/pull/68 . You might try the same test...
Have you tried tuning `fetch_max_bytes` ? It defaults to 50MB, which is probably too big if you've only got 128MB to work with.
The structs for this are currently in `kafka.coordinator.protocol` . We could move these to kafka.protocol.group or just link from there to where they are now (as long as there is...
Sounds interesting -- PRs welcome!
Follow-up KAFKA-3303
I do not have any plans for this. But I'm happy to take community PRs! On Tue, Aug 27, 2019, 6:05 AM Vimal Dinakaran wrote: > @dpkp is there a...
There were a few bugfixes to group coordinator reconnects in 1.3.3. First thing to do if you see an error like this is verify you are on latest release (@markerdmann,...
kafka-python supports `wakeup` via a socketpair in KafkaClient. This allows threads sharing a KafkaClient instance that is blocked waiting for IO to signal that wakeup is desired for other processing....
There is no mechanism to update SASL authentication after initial connection. So I think what would have to happen here is the connection would have to be closed and reconnected...