Checklist

[*] I have included information about relevant versions
[*] I have verified that the issue persists when using the master branch of Faust.

Steps to reproduce

Create a simple agent and try to read messages from the topic.

Expected behavior

Expect valid message receiving without any warnings and errors

Actual behavior

Receive such warnings: [2021-11-11 03:07:14,256] [8875] [WARNING] AttributeError [2021-11-11 03:07:14,256] [8875] [WARNING] : [2021-11-11 03:07:14,256] [8875] [WARNING] 'ThrowableQueue' object has no attribute 'put_nowait_enhanced' [2021-11-11 03:07:14,256] [8875] [WARNING] Exception ignored in: [2021-11-11 03:07:14,256] [8875] [WARNING] 'faust.transport._cython.conductor.ConductorHandler._put' [2021-11-11 03:07:14,256] [8875] [WARNING] Traceback (most recent call last): [2021-11-11 03:07:14,256] [8875] [WARNING] File "/Library/Frameworks/Python.framework/Versions/3.8/lib/python3.8/site-packages/faust/transport/conductor.py", line 274, in on_message [2021-11-11 03:07:14,257] [8875] [WARNING] return await get_callback_for_tp(message.tp)(message) [2021-11-11 03:07:14,257] [8875] [WARNING] AttributeError [2021-11-11 03:07:14,257] [8875] [WARNING] : [2021-11-11 03:07:14,257] [8875] [WARNING] 'ThrowableQueue' object has no attribute 'put_nowait_enhanced'

And no received data in a log

Full traceback

Paste the full traceback (if there is any)

Versions

Python version: 3.8.10
Faust version: faust-streaming 0.6.10
Operating system: MacOS 12.0.1 (21A559)
Kafka version: confluent-kafka 6.2.0
RocksDB version: 0.7.0

faust-streaming / faust