kafka 开启认证模式，命令行工具kafka-console-producer.sh kafka-console-consumer.sh无法使用报错

kafka的配置

测试环境kafka配置了认证模式
security.inter.broker.protocol=SASL_PLAINTEXT
sasl.enabled.mechanisms=PLAIN

此时，如果直接运行 生产者命令行

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test

可能会有如下报错

[2022-11-03 10:53:32,911] WARN [Producer clientId=console-producer] 
Connection to node -1 (localhost/127.0.0.1:9092) could not be established. 
Broker may not be available. (org.apache.kafka.clients.NetworkClient)

运行 消费组命令行工具，也会报错

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

原因

由于 kafka开启了认证，如果命令行工具中 不加认证参数，就没有办法成功链接

修改

修改生产者命令行

bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test-topic --producer-property security.protocol=SASL_PLAINTEXT --producer-property sasl.mechanism=PLAIN

修改消费组命令行

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning --consumer-property security.protocol=SASL_PLAINTEXT --consumer-property sasl.mechanism=PLAIN