Updated aiokafka

• aiokafka dependency updated to be >=0.7.1 and <0.8.0

Stability fixes

• Error when logging slow process in aiokafka with python 3.9 153
• FIX Record instances deserialize properly when returned by agent.ask151

Bug Fixes

• Unit tests coverage improvements. Thanks to @taybin
• Fix for #149

Bug Fixes

• Fix partition from message for globaltables or tables that use partitioner 129
• Calling window close callback after popping the value from store 137

Bug Fixes

• Add app_name to prometheus sensors120
  -DatadogMonitor - IndexError: deque index out of range113

Bug Fixes

• fix agents with multiple topics116
• Simplify the code by getting rid of deque_pushpopmax in favour of using maxlen= parameter of deque115
• fixes a race condition in writing messages to topics that resulted in a violation of the ordering guarantee (especially changelog topics)112

Adding AeroSpike support

v0.6.0

annotation for this release

Partition Assignment Fix

fix extra parameter (#101) (#109)

* fix extra parameter in on_rebalance call (#101)

Rebalance Fixes and Rocksdb features

Please update your rocksdb bindings to use faust-streaming-rocksdb>=0.8.0

• Allow multiple workers to share rocksdb data dir98
• Fix rebalance and recovery issues 83
  -92

Critical Fixes

• Fix for 85
• Fix for 88
• Fix for 91
• Enabled Tests 79
• Fix for 84