消费者连接到 kafka 服务器时，SASL 握手期间出现意外的 METADATA 类型的 Kafka 请求

Question

我在 Windows 11 上有“kafka_2.13-3.7.0”

我想使用 SASL_PLAINTEXT 运行 kafka，我按照 https://kafka.apache.org/documentation/#security_sasl_plain

中的步骤操作

我在文件 server.properties 中添加了以下设置

listeners=SASL_PLAINTEXT://localhost:9092
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.mechanism.inter.broker.protocol=PLAIN
sasl.enabled.mechanisms=PLAIN

我定义了一个配置文件“kafka_jaas.conf”，其中包含以下内容

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

然后我用下面的JVM启动了kafka服务器，服务器启动成功了

-Djava.security.auth.login.config=kafka_jaas.conf

然后我在consumer.properties中添加了以下内容

sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required username="alice"   password="alice-secret";  
security.protocol=SASL_PLAINTEXT  
sasl.mechanism=PLAIN

最后我运行了一个消费者 kafka-console-consumer.bat --topic my-topic --from-beginning --bootstrap-server localhost:9092

但我收到以下错误 [2024-06-01 23:51:57,041] INFO [SocketServer ListenerType=ZK_BROKER, nodeId=0] 身份验证失败 /127.0.0.1 (channelId=127.0.0.1:9092-127.0.0.1:56526-5) (意外的 Kafka SASL 握手期间元数据类型的请求。）（org.apache.kafka.common.network.Selector）

谁能帮帮我，谢谢。

希望kafka消费者启动成功。

Answer 1

consumer.properties

文件必须由

--consumer.config

为控制台消费者提供