我正在尝试将具有 conf 属性security.protocol
生产者连接到明文。 如何在调用RdKafka::Producer::create
之前将username
和password
传递给Conf
对象?
set
电话似乎都不合适。 我阅读了有关 sasl 的文档以获取灵感,但它没有帮助。
使用:
sasl.username
sasl.password