github aio-libs/aiokafka v0.2.2
More bugfix for Consumer and reconnects

latest releases: v0.11.0, v0.10.0, v0.10.0.a0...
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.