Kafka0.10 SASL/普通制作人超时

Question

我在Cloudera中安装了一个3代理kerberised Kafka 0.10，我正在尝试通过SASL/PLAIN进行身份验证

我路过Kafka·贾斯。配置到每个代理上的JVM中。

KafkaServer{org.apache.kafka.common.security.plain.PlainLoginModule所需用户名=管理员密码=密码1用户\ u管理员=密码1用户\ u远程=密码1；}

我的服务器。属性（或Cloudera重命名时的kafka.properties）设置如下；

listeners=SASL_SSL://10.10.3.47:9093#为每个发布的代理设置ip。listeners=SASL_SSL://10.10.3.47:9093#每个代理SASL的ip集。启用。机制=GSSAPI，普通安全。埋葬经纪人协议=SASL_SSL SASL。机械装置埋葬经纪人协议=GSSAPI

当Kafka启动时，代理间的通信一切正常，但当我尝试使用控制台生成器进行连接时，我得到一个超时，无法更新元数据

bin/kafka控制台制作人——经纪人列表10.10.3.161:9093——主题测试1——制作人。配置客户端。财产。普通的

客户财产。平原被设置为

安全。协议=SASL_SSL SASL。机械装置=普通

最后，客户端jaas.conf

KafkaClient{org.apache.kafka.common.security.plain.PlainLoginMoules必需用户名="远程"密码="Password1"; };

据我所知，我已经正确地遵循了所有的指示，有人看到什么错误吗？

更新我已经把控制台消费者的日志记录调高了一点，我得到了以下错误；

[2017-03-02 13:17:50817]跟踪SSLHandshake需要_unwrapchannelid-1，握手结果状态=OK HandshakeStatus=FINISHED bytesConsumed=101 BytesProducted=0，appReadBuffer位置0，netReadBuffer位置0，netWriteBuffer位置101（org.apache.kafka.common.network.sslttransportlayer）[2017-03-02 13:17:50817]跟踪SSLHandshake完成的通道ID-1，appReadBuffer位置0，netReadBuffer位置0，netWriteBuffer pos 101（org.apache.kafka.common.network.sslttransportlayer）[2017-03-02 13:17:50817]调试设置SASL客户端状态以接收握手响应（org.apache.kafka.common.security.authenticator.SaslClientAuthenticator）[2017-03-02 13:17:50818]调试将SASL客户端状态设置为初始状态（org.apache.kafka.common.security.authenticator.SaslClientAuthenticator）[2017-03-02 13:17:50819]调试将SASL客户端状态设置为中间状态（org.apache.kafka.common.security.authenticator.SaslClientAuthenticator）[2017-03-02 13:17:50820




Answer 1

在我的例子中，没有必要添加明文监听器或发布监听器。相反，这个问题出现在我的kafka_server_jaas.conf.将username属性设置为客户端登录时使用的名称为我解决了这个问题。

Answer 2

我对SASL_明文授权也有类似的问题。我可以连接到代理（通过kafka python），但我从制作人那里发送的任何消息都会超时。

我最终为SASL_PLAINTEXT和PLAINTEXT侦听器做了广告，但只通过AWS安全组公开了SASL_PLAINTEXT侦听器。

我的服务器_jaas。基本上是一样的。

我的服务器。属性使用了以下设置：

security.inter.broker.protocol=PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN
advertised.listeners=SASL_PLAINTEXT://example.com:9095,PLAINTEXT://example.com:9092
listeners = SASL_PLAINTEXT://0.0.0.0:9095,PLAINTEXT://0.0.0.0:9092

我在用kafka python客户端调试它，我的命令看起来像这样（python）

from kafka import KafkaProducer
producer = KafkaProducer(bootstrap_servers='example.com:9095', security_protocol="SASL_PLAINTEXT", sasl_mechanism='PLAIN', sasl_plain_username='username', sasl_plain_password='password')

通过这种设置，我能够进行用户名/密码身份验证，还可以生成和使用发送给代理的消息，而无需超时。

希望这能有所帮助：）