aio-libs/aiokafka v0.14.0b1

on GitHub

New features:

• Add rack-aware fetching from the closest in-sync replica (KIP-392) via the new
  client_rack option on :class:AIOKafkaConsumer. When set and the brokers
  support FetchRequest v11 (Kafka 2.4+) with a replica.selector.class
  configured, the consumer will fetch from a same-rack follower instead of the
  partition leader, reducing cross-AZ traffic and tail latency.
  (prs #1159 and #1160 by @GlebShipilov)

Bugfixes:

• Fix type annotation for AIOKafkaAdminClient (issue #1148)
• Return back and deprecate api_version parameter in client classes
  (issue #1147)
• Avoid failures when a transaction coordinator is dead by removing deprecated code
  (issue #1151)
• Properly manage batch max size and linger_ms. A batch will be always
  produced if the max size or the lingering time is reached
  (pr #1142 by @vmaurin)