solidguy7

Thanks for your reply! Actually, I`ve tried this method, but I have stuck using it. I create test code snippet like this: ```python import asyncio from aiokafka import AIOKafkaConsumer, TopicPartition...

I have also tried this method. It returns None, but my test topic has been created