You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Traceback (most recent call last):
File "/home/<user>test_manual/kafka_notifier_manual_test.py", line 130, in <module>
asyncio.run(err_on_genmany())
File "/usr/lib/python3.11/asyncio/runners.py", line 190, in run
return runner.run(main)
^^^^^^^^^^^^^^^^
File "/usr/lib/python3.11/asyncio/runners.py", line 118, in run
return self._loop.run_until_complete(task)
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
File "/usr/lib/python3.11/asyncio/base_events.py", line 653, in run_until_complete
return future.result()
^^^^^^^^^^^^^^^
File "/home/<user>test_manual/kafka_notifier_manual_test.py", line 121, in err_on_genmany
await kc.getmany()
File "/home/<user>/.local/share/virtualenvs/<dir>-2sgYN4mf/lib/python3.11/site-packages/aiokafka/consumer/consumer.py", line 1208, in getmany
self._coordinator.check_errors()
^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
AttributeError: 'NoneType' object has no attribute 'check_errors'
The text was updated successfully, but these errors were encountered:
Describe the bug
If a consumer is created but not started and the
genmany()
method is called, an AttributeError results.Expected behaviour
A user friendly error that explains the problem should be thrown.
Environment (please complete the following information):
Reproducible example
Results in the output:
The text was updated successfully, but these errors were encountered: