Учетные данные Kafka и параметры потребителя для клиента C++

Question

Я пытаюсь использовать kafka msg с помощью С ++. Я установил librdkafka и попробовал пример https://github.com/edenhill/librdkafka/blob/master/examples/rdkafka_example.cpp

Теперь меня беспокоит, как передать имя пользователя, пароль и хранилище доверенных сертификатов потребителю kafka?

Answer 1

В зависимости от того, с каким механизмом аутентификации настроен брокер, вам необходимо настроить клиента со следующими свойствами конфигурации:

• security.protocol=SASL_PLAINTEXT или SASL_SSL, в зависимости от того, используется ли SSL.
• sasl.mechanism=PLAINили любой другой механизм, см. CONFIGURATION.md
• sasl.username=... а также sasl.password=.. для механизмов PLAIN и SCRAM-...
• sasl.kerberos.service.name=.. для GSSAPI/Kerberos.

См. CONFIGURATION.md для получения всех доступных свойств конфигурации, механизмов SASL и т. Д.