FastKafka is a powerful and easy-to-use Python library for building asynchronous web services that interact with Kafka topics. Built on top of Pydantic, AIOKafka and AsyncAPI, FastKafka simplifies the process of writing producers and consumers for Kafka topics.
We need to remove nest_asyncio.apply logig when starting the brokers in notebooks: ApacheKafkaBroker and LocalRedPandaBroker
After that, failing tests should show where we need to apply the nest_asyncio manually and not automatically in the broker
We need to remove nest_asyncio.apply logig when starting the brokers in notebooks: ApacheKafkaBroker and LocalRedPandaBroker After that, failing tests should show where we need to apply the nest_asyncio manually and not automatically in the broker