Может кто-нибудь подсказать, как написать потребитель для кафки сервера (авро схема). Я нашел приведенный ниже код пользователя, но он не может прочитать данные, опубликованные в топи c.
consumer = AvroConsumer({'bootstrap.servers': 'localhost:9092', 'schema.registry.url': 'localhost:8081','group.id': 'mygroup'})
Спасибо