B.T*_*ong 4 apache-kafka message-hub
我使用 node-rdkafka 通过以下选项连接到 IBM MessageHub:
var options = {
// 'debug': 'all',
'metadata.broker.list': brokers,
'security.protocol': 'sasl_ssl',
'ssl.ca.location': '/etc/ssl/certs',
'sasl.mechanisms': 'PLAIN',
'sasl.username': username,
'sasl.password': password,
'api.version.request': true,
'broker.version.fallback': '0.10.2.1',
'log.connection.close': false,
'dr_msg_cb': true
}
Run Code Online (Sandbox Code Playgroud)
客户端在 IBM Kubernetes Service pod (Ubuntu) 上运行。
请指教。谢谢。
这意味着您在安装/构建 node-rdkafka 时缺少一些依赖项(SSL 或 SASL)。
在 ubuntu 上确保您已经安装了libsasl2-dev, 。libsasl2-moduleslibssl-dev
您可以查看我们的node-rdkafka 示例 Dockerfile以获取工作示例。
| 归档时间: |
|
| 查看次数: |
6510 次 |
| 最近记录: |