Как я могу подключиться к серверу начальной загрузки Kafka через SASL_SSL с помощью rdkafka? ⇐ Php

[Anonymous]

Я пытаюсь подключиться к брокеру сообщений с помощью rdkafka Github, пытаясь подключиться к серверу Confluent Boostrap. Однако моя попытка получить сообщения не удалась из-за ошибки аутентификации.
У меня нет доступа к серверу удаленного брокера, сообщения предоставляются как услуга «открытых данных» для общего доступа. общедоступно.

Код: Выделить всё

Kafka bootstrap server: ###.europe-west2.gcp.confluent.cloud:9092
SASL mechanism: PLAIN
SASL config: org.apache.kafka.common.security.plain.PlainLoginModule
Security protocol: SASL_SSL

Мой потребительский файл PHP использует приведенную ниже конфигурацию с использованием имени пользователя и пароля, предоставленных мне поставщиком данных.

Код: Выделить всё

$conf = new RdKafka\Conf();
$conf->set('group.id', 'myGroup');
$conf->set('bootstrap.servers', '##.europe-west2.gcp.confluent.cloud:9092');
$conf->set('sasl.username', '####');
$conf->set('sasl.mechanisms', 'PLAIN');
$conf->set('sasl.password', '####');
$conf->set('security.protocol', 'SASL_SSL');

Ответ об ошибке, выданный программой rdkafka:

Код: Выделить всё

%3|1729596043.057|FAIL|rdkafka#consumer-1| [thrd:sasl_ssl://###.europe-west2.gcp.confluent.cloud:9092/boot]: sasl_ssl://pkc-l6wr6.europe-west2.gcp.confluent.cloud:9092/bootstrap: SASL authentication error: Authentication failed (after 5002ms in state AUTH_REQ)

%3|1729596043.058|ERROR|rdkafka#consumer-1| [thrd:sasl_ssl://###.europe-west2.gcp.confluent.cloud:9092/boot]: 1/1 brokers are down

%3|1729596043.058|ERROR|rdkafka#consumer-1| [thrd:app]: rdkafka#consumer-1: sasl_ssl://###.europe-west2.gcp.confluent.cloud:9092/bootstrap: SASL authentication error: Authentication failed (after 5002ms in state AUTH_REQ)

Проблема аналогична этому вопросу на форуме Confluent: я запустил команду telnet на порту, и он успешно подключается.
Кто-нибудь знает, чего мне может не хватать в моей конфигурации? Я рассматривал возможность добавления свойства sasl_jaas_config, но rdkafka не поддерживает JAAS. Излишне говорить, что эта проблема с Github, похоже, предполагает, что она мне не нужна, достаточно просто указать имя пользователя sasl_username и пароль...
Спасибо. Новое в Kafka.
https://github.com/confluentinc/librdkafka/issues/2510

Подробнее здесь: https://stackoverflow.com/questions/791 ... th-rdkafka