NoGroupCoordinator Task was destroyed but it is pending

[TomGoBravo]

I'm calling aiokafka directly to work around limitations of the faust abstractions. I've run into the following stack trace (output thanks to PYTHONASYNCIODEBUG=1). It seems to happen after I've consumed all messages from a couple topics, subscribed to two topics (one the same as before and another), changed the position within the topics and then called getone(). Is there something obviously wrong?

Executing <Handle <TaskWakeupMethWrapper object at 0x7f76975e85b8>(<Future finis...events.py:275>) created at /srv/venvs/service/tr[13/1948]
ice_venv_python3.6/lib/python3.6/site-packages/aiokafka/consumer/fetcher.py:439> took 1.332 seconds
Task was destroyed but it is pending!
source_traceback: Object created at (most recent call last):
  File "./async_updater.py", line 201, in <module>
    run_async()
  File "/srv/venvs/service/trusty/service_venv_python3.6/lib/python3.6/site-packages/click/core.py", line 722, in __call__
    return self.main(*args, **kwargs)
  File "/srv/venvs/service/trusty/service_venv_python3.6/lib/python3.6/site-packages/click/core.py", line 697, in main
    rv = self.invoke(ctx)
  File "/srv/venvs/service/trusty/service_venv_python3.6/lib/python3.6/site-packages/click/core.py", line 895, in invoke
    return ctx.invoke(self.callback, **ctx.params)
  File "/srv/venvs/service/trusty/service_venv_python3.6/lib/python3.6/site-packages/click/core.py", line 535, in invoke
    return callback(*args, **kwargs)
  File "./async_updater.py", line 196, in run_async
    loop.run_until_complete(conductor.run())
  File "/usr/lib/python3.6/asyncio/base_events.py", line 454, in run_until_complete
    self.run_forever()
  File "/usr/lib/python3.6/asyncio/base_events.py", line 421, in run_forever
    self._run_once()
  File "/usr/lib/python3.6/asyncio/base_events.py", line 1418, in _run_once
    handle._run()
  File "/usr/lib/python3.6/asyncio/events.py", line 127, in _run
    self._callback(*self._args)
  File "/usr/lib/python3.6/asyncio/coroutines.py", line 125, in send
    return self.gen.send(value)
  File "/srv/venvs/service/trusty/service_venv_python3.6/lib/python3.6/site-packages/aiokafka/consumer/group_coordinator.py", line 149, in _
reset_committed_routine
    commit_refresh_needed.wait(), loop=self._loop)
task: <Task pending coro=<Event.wait() running at /usr/lib/python3.6/asyncio/locks.py:271> wait_for=<Future pending cb=[<TaskWakeupMethWrapp
er object at 0x7f76af3e8be8>()] created at /usr/lib/python3.6/asyncio/base_events.py:275> created at /srv/venvs/service/trusty/service_venv_
python3.6/lib/python3.6/site-packages/aiokafka/consumer/group_coordinator.py:149>
Executing <Handle <TaskWakeupMethWrapper object at 0x7f76971a4e28>(<Future finis...events.py:275>) created at /usr/lib/python3.6/asyncio/tas
ks.py:390> took 0.108 seconds