使用节点rdkafka的kerberos sasl身份验证

2sbarzqh  于 2021-06-06  发布在  Kafka
关注(0)|答案(0)|浏览(543)

我在尝试连接到使用节点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)。我必须设置某种环境变量吗?我找不到任何例子或解决办法。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题