我使用节点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
}
客户机运行在ibmkubernetes服务pod(ubuntu)上。
请给我建议。谢谢。
1条答案
按热度按时间mkshixfv1#
这意味着您在安装/构建节点rdkafka时缺少一些依赖项(ssl或sasl)。
在ubuntu上确保
libsasl2-dev
,libsasl2-modules
以及libssl-dev
安装。您可以查看我们的节点rdkafka示例dockerfile以获得一个工作示例。