我正在使用 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
}
客户端在 IBM Kubernetes Service pod (Ubuntu) 上运行。
请指教。谢谢。