Tom Most

No, no need to support MessageSet v0. We already dropped support for brokers that old in Afkak. It's best not to wait for me, as I have lots of tasks...

Just to follow up on throttling, I stumbled across the primary KIP for it: [KIP-124 Request rate quotas](https://cwiki.apache.org/confluence/display/KAFKA/KIP-124+-+Request+rate+quotas). It looks like the field is just an FYI — it is...

Here's a draft: # Release Procedure 1. Update version in `setup.py` and `afkak/__init__.py`. 2. Update the changelog with the new version number. Review the release notes, editing and reformatting as...

#56 will fix this.

Now with `PartitionUnavailableError` instead: ``` ERROR: afkak.test.test_consumer_integration.TestConsumerIntegration.test_large_messages ---------------------------------------------------------------------- Traceback (most recent call last): File "/home/travis/build/ciena/afkak/.tox/py36-int-snappy-murmur/lib/python3.6/site-packages/twisted/internet/defer.py", line 151, in maybeDeferred result = f(*args, **kw) File "/home/travis/build/ciena/afkak/.tox/py36-int-snappy-murmur/lib/python3.6/site-packages/twisted/internet/utils.py", line 201, in runWithWarningsSuppressed reraise(exc_info[1],...

Yeah, absolutely. The only way to tell if you can actually produce to or consume from a topic is to try doing so.

Maybe we should change Afkak's retry strategy to compensate for this? Right now we fail eagerly with `PartitionUnavailableError` based on the metadata. In practice I think that this just pushes...

I stole some of the benchmarks here for #12258 so we can get some baseline measurements on trunk.

We should also deprecate `Failure.throwExceptionIntoGenerator`, as it is more-or-less an implementation detail of `inlineCallbacks` and `deferredGenerator`.

PR to prevent recurrence here: https://github.com/pypi/warehouse/pull/16529