pypi aiokafka 0.2.2
More bugfix for Consumer and reconnects

latest releases: 0.10.0, 0.10.0a0, 0.9.0...
7 years ago
  • Force reconnect after KafkaTimeoutException. (PR #149 by @Artimi)
  • Fixed compacted topic handling. It could skip messages if some of them were
    compacted (issue #71)
  • Fixed old issue with new topics not visible in pattern subscription (issue #46)
  • Another fix for Consumer race condition on JoinGroup. This forces Leader to
    wait for new metadata before assigning partitions. (issue #118)
  • Changed metadata listener in Coordinator to avoid 2 rejoins in a rare
    condition (issue #108)
  • getmany will no longer return 0 results before timeout. (issue #117)

Big thanks to @Artimi for pointing out several of those issues.

Don't miss a new aiokafka release

NewReleases is sending notifications on new releases.