[QUESTION] Is aiokafka consumer thread safe?

[DavidOsparks]

confluent-kafka-python says "Producer, Consumer and AdminClient are all thread safe."
kafka-python says "while it is possible to use the KafkaConsumer in a thread-local manner, multiprocessing is recommended."
However, I cannot find any description about thread safety in the document of aiokafka, so I worry about if AIOKafkaConsumer is thread safe? Whether it is or not, maybe it should be mentioned in the document.

[vmaurin]

In python, all the "aio/async" libraries run over an event loop. An event loop is always run by a single thread, managing multiple concurrent queries. So the first sentence of the documentation

aiokafka is a client for the Apache Kafka distributed stream processing system using asyncio.

should be enough to indicate about the threading model

[antonagestam]

Not really. A piece of code designed for asyncio does not by design either support or not being run across multiple threads.

[DavidOsparks]

Thanks. I checked some docs, maybe we can say that:

1. asyncio is not totally thread-safe. In fact, it is almost totally not thread-safe.
2. But under some conditions, we can still use asyncio with multithreading.

https://docs.python.org/3/library/asyncio-dev.html#concurrency-and-multithreading
"Almost all asyncio objects are not thread safe, which is typically not a problem unless there is code that works with them from outside of a Task or a callback."

https://docs.python.org/3/library/asyncio-sync.html
"asyncio primitives are not thread-safe, therefore they should not be used for OS thread synchronization (use threading for that)"

However, back to original question: is aiokafka consumer thread-safe? I have no idea if aiokafka uses asyncio (or some other things) unsafely.