Add aiokafka.connect coroutine