使用快速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";
网友评论