Ошибка '''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

Адекватного решения нигде не нашел, может тут кто подскажет.


Ответы (0 шт):