Айокафка не подключается молча

Я пытаюсь подключить потребителя aiokafka со следующей конфигурацией.

          kafka_config = {
        "bootstrap_servers": "b-2.cpkafkacluster-2106.vi24p2.c1.kafka.eu-central-1.amazonaws.com:9096",
        "security_protocol": "SASL_SSL",
        "sasl_mechanism": "SCRAM-SHA-512",
        "sasl_plain_username": "valid_username",
        "sasl_plain_password": "valid_password",
        "ssl_context": create_ssl_context(),
        "retry_backoff_ms": 500,
        "request_timeout_ms": 20000,
        "group_id": "some_group_id",
    }

При таком запуске и блокировке у логов прилетает только следующая лог айокафка, не более того. Вроде как ни ошибки не произошло, но и соединение не установлено (у меня тоже не видит группу консьюмеров в kafdrop и тоже не приходят сообщения на консьюмер)

      <AIOKafkaConnection host=b-2.cpkafkacluster-2106.vi24p2.c1.kafka.eu-central-1.amazonaws.com port=9096> Response 1: SaslHandShakeResponse_v0(error_code=0, enabled_mechanisms=['SCRAM-SHA-512'])
      <AIOKafkaConnection host=b-2.cpkafkacluster-2106.vi24p2.c1.kafka.eu-central-1.amazonaws.com port=9096> Request 1: SaslHandShakeRequest_v0(mechanism='SCRAM-SHA-512')

Я немного в недоумении, что происходит.

Дополнительная информация:

  • Другой потребитель, использующий kafka-python с той же конфигурацией, работает
  • Локальное выполнение с изображением докера kafka без SASL также работает

0 ответов

Другие вопросы по тегам