使用快速docker安装kafak cli 连接SASL认证的K

使用快速docker安装kafak cli

docker run -it  wurstmeister/kafka /bin/bash

kafka-console-consumer.sh --bootstrap-server ${host}:9092 --topic test --from-beginning

安装vim
 apk add --update vim
cd /opt/kafka_2.13-2.7.0/config
生产：
kafka-console-producer.sh --broker-list ${连接地址} --topic ${Topic名称} --producer.config ./producer.properties
消费：
./kafka-console-consumer.sh --bootstrap-server ${连接地址} --topic ${Topic名称} --group ${消费组名称} --from-beginning  --consumer.config ./consumer.properties

在Kafka命令行工具的"/opt/kafka_2.13-2.7.0/config"目录中找到“consumer.properties”和“producer.properties”文件，并分别在文件中增加如下内容。

security.protocol=SASL_PLAINTEXT
sasl.mechanism=PLAIN
sasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required\n\
username="user"\n\
password="passwd";