Как использовать Librdkafka с OIDC и Azure AD в качестве поставщика токенов для Oauthbearer? ⇐ C++

[Anonymous]

проблема
Я хочу использовать kafka oidc с Azure ad в качестве поставщика токенов, но я застрял на некоторых странных ошибках. с Python и C ++.
, включая OAuth (который использует Azure AD) примеры, перечисленные в https://github.com/azure/azure-event-hu ... uth/python forments, когда я использовал, когда я использовал, когда я использовал, когда я использовал, когда я использовал достоинства
, когда я использовал достоинства . Зарегистрированное приложение веб-страницы после https://learn.microsoft.com/en-us/azure ... ocols-oidc и, используя конечную точку v2, я закончил ошибкой | rdkafka#Производитель-1 | [thrd: app]: rdkafka#продюсер-1: sasl_ssl: //myhub.servicebus.windows.net: 9093/bootstrap: Ошибка аутентификации SASL: неверный URI: формат URI не может быть определен. (Через 272 мс в штате auth_req) < /code>.
Для V1 без прицела ошибка аналогична - Fail | rdkafka#Производитель -1 | [thrd: sasl_ssl: //myhub.servicebus.windows.net: 9093/bootstrap]: sasl_ssl: //myhub.servicebus.windows.net: 9093/bootstrap: SASL Authentication Ошибка: Неверный URI: формат URI не определяется. (Через 259 мс в штате auth_req).
setup
Опять же, все существующие примеры, которые я проверял для меня, но ни один из тех, кто использует OIDC. sasl.oauthbearer.config Чтобы сделать эту работу?
conf->set("bootstrap.servers", "myhub.servicebus.windows.net:9093", errstr);
conf->set("security.protocol", "SASL_SSL", errstr);
conf->set("sasl.mechanism", "OAUTHBEARER", errstr);
conf->set("sasl.oauthbearer.method", "oidc", errstr);
conf->set("sasl.oauthbearer.client.id", "***", errstr);
conf->set("sasl.oauthbearer.client.secret", "***", errstr);
conf->set("sasl.oauthbearer.token.endpoint.url", "https://login.microsoftonline.com/***/oauth2/v2.0/token", errstr);
conf->set("sasl.oauthbearer.scope", "api://***/.default", errstr);

ссылки
confluent kafka oidc - https://cwiki.apache.org/confluence/pag ... 575,/p>br/> c+ librcafka oidc. -oidcafka oidcafka -oidcafka -oidcafka -oidcafka -oidcafka -oidcafka https://github.com/edenhill/librdkafka/ ... idc.c#l242 https://github.com/azure/azure-event-hu ... issues/223> отредактировано:
Дальнейшая отладка с помощью отладки = все показано, что токен oauthbearer получается, в то время как приложение не удается при отладке.SASL OAUTHBEARER client in state client-first-message
Send SASL Kafka frame to broker
Sent SaslAuthenticateRequest

Received SaslAuthenticateResponse
Invalid URI: The format of the URI could not be determined.


Подробнее здесь: https://stackoverflow.com/questions/746 ... authbearer