jabonte

stream.take does not decrement events_active

3

## Steps to reproduce use stream.take and watch the app.monitor events_active counter. ``` #!/usr/bin/env python3 import random import ssl import faust def main_loop(): app = get_faust() topic = app.topic( 'test-topic-stream-take',...

Offsets not commited due to duplicate in _acked

4

platform: CPython 3.6.8 (Linux x86_64) faust: v1.10.4 transport: aiokafka=1.1.6 web: aiohttp=3.6.2 kafka: 2.4.0 Problem: sometimes offsets are not being committed, but messages are still being processed Occurs: when there are...