Айокафка не подключается молча
Я пытаюсь подключить потребителя 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 также работает