Ошибка '''incompatiblebrokerversion: kafka broker does not support the 'createtopicsrequest_v0' kafka protocol.'''
Разрабатываю простенький сервис email-рассылок на FastAPI. Понял (да и подсказали здесь же), что желательно использовать Kafka для обработки большой нагрузки. Поднял kafka через docker:
- версия kafka - 3.1.0 ('docker.io/bitnami/kafka:3.1.0'),
- версия zookeper - 3.8.0 ('docker.io/bitnami/zookeeper:3.8.0').
- Установил aiokafka версии 0.11.0 (первая на Pypi), при попытке создать тему, как я понял, выдает ошибку:
aiokafka.errors.incompatiblebrokerversion:
incompatiblebrokerversion:
kafka broker does not support the 'createtopicsrequest_v0' kafka protocol
Адекватного решения нигде не нашел, может тут кто подскажет.