SASL握手期间METADATA类型的意外Kafka请求

Question

我正在尝试使用SASL平原将Kafka Java客户端连接到Kafka代理。但是当我试图从生产者那里发送消息时，Kafka服务器记录了以下错误:

[2020-04-30 14:48:14,955] INFO [SocketServer brokerId=0] Failed authentication with /127.0.0.1 (Unexpected Kafka request of type METADATA during SASL handshake.) (org.apache.kafka.common.network.Selector)

看起来，生产者试图在SASL握手之前发送一个元数据请求。我如何在发送消息之前进行握手？

下面是我的< code > kafka _ Server _ JAAS . conf 文件，用于Kafka服务器。

KafkaServer {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="admin"
    password="admin-secret"
    user_admin="admin-secret";
};

Client {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="admin"
    password="admin-secret";
};

以下是我的zookeeper_jaas。conf文件，用于动物园管理员：

Server {
    org.apache.kafka.common.security.plain.PlainLoginModule required
    username="admin"
    password="admin-secret"
    user_admin="admin-secret";
};

在我的Java producer中，我设置了以下属性:

java prettyprint-override">Properties properties = new Properties();
properties.put("bootstrap.servers", "localhost:9092");
properties.put("sasl.jaas.config", "org.apache.kafka.common.security.plain.PlainLoginModule required username=\"admin\" password=\"admin_secret\"");
properties.put("sasl.mechanisms", "PLAIN");
properties.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");
KafkaProducer kafkaProducer = new KafkaProducer(properties);

我做错什么了吗？

Answer 1

您需要指定< code>security.protocol，否则默认情况下，Kafka客户端不使用< code>SASL。

在客户端属性中，添加：

properties.put("security.protocol", "SASL_SSL");

还有< code > SASL _明文，但不建议对< code > SASL _明文使用< code >明文机制，因为这样可以有效地以明文形式交换密码。