Add aiokafka.connect coroutine
WIP: consumers
fixed consumer and more tests
flake8
dirty port of consumers
remove unused consts