我在尝试连接到使用节点rdkafka npm模块的kerberos sasl身份验证的kafka示例时遇到了一个问题,由于缺少文档和示例,解决这个问题非常困难。我正在使用这里找到的alpine设置来拉入所有必需的librdkafka和节点rdkafka依赖项并创建一个映像。我正在尝试使用以下配置对象运行容器,以便节点rdkafka生产者连接到kafka示例:
'debug': 'all',
'client.id': 'kafka',
'metadata.broker.list': KAFKA_DOMAINS,
'sasl.kerberos.principal': '<id>@<REALM>',
'sasl.kerberos.keytab': '/path/to/<id>.keytab',
'sasl.kerberos.service.name': 'kafka',
'security.protocol': 'sasl_plaintext',
'sasl.kerberos.kinit.cmd': 'kinit -kt /path/to/<id>.keytab <id>@<REALM>',
'dr_cb': true,
'event_cb': true
当我尝试运行容器时,它挂起,然后抛出以下错误:
[2019-02-05T17:09:59.637Z] ERROR: kafka/7 on 95c927d11411: broker transport failure (err.code=-195)
Error: Local: Broker transport failure
at Function.createLibrdkafkaError [as create] (/opt/rdkafka/node_modules/node-rdkafka/lib/error.js:261:10)
at /opt/rdkafka/node_modules/node-rdkafka/lib/client.js:339:28
以下是features和libkafkaversion log语句的输出:
[2019-02-05T17:09:29.519Z] INFO: kafka/7 on 95c927d11411:
[ 'gzip',
'snappy',
'ssl',
'sasl',
'regex',
'lz4',
'sasl_gssapi',
'sasl_plain',
'sasl_scram',
'plugins' ]
[2019-02-05T17:09:29.521Z] INFO: kafka/7 on 95c927d11411: 0.11.5
我错过了什么,我无法连接?我是否缺少一些环境变量?我知道librdkafka的java实现涉及到传递领域、kdc\u主机和一些.conf文件(krb5和jaas)。我必须设置某种环境变量吗?我找不到任何例子或解决办法。
暂无答案!
目前还没有任何答案,快来回答吧!