西安微信商城网站设计,杭州排名优化软件,国外 网站源码,传统建筑网站首先参考文档#xff0c;思考过程可以进行参考https://juejin.cn/post/7294556533932884020#heading-3
用的镜像是Bitnami#xff0c;对SASL配置进行了简化#xff0c;需要按照特定格式去配置jass验证 完整配置如下 镜像版本参考#xff1a;https://hub.docker.com/r/bitn…首先参考文档思考过程可以进行参考https://juejin.cn/post/7294556533932884020#heading-3
用的镜像是Bitnami对SASL配置进行了简化需要按照特定格式去配置jass验证 完整配置如下 镜像版本参考https://hub.docker.com/r/bitnami/kafka/tags
KAFKA_KRAFT_CLUSTER_ID这里需要固定一个uuid
# 使用Linux工具生成Kafka格式的集群ID
UUID$(uuidgen | tr -d -)
echo $UUID | xxd -r -p | base64启动以后宿主机kafka的目录结构如下
tree kafka/
kafka/
└── kafka├── config└── data我最终选择一个固定版本防止某天重启后发生异常错误
version: 3
services:kafka:image: bitnami/kafka:3.5.1container_name: kafkaports:- 9092:9092volumes:- /data/kafka:/bitnamienvironment:# KRaft 模式配置- KAFKA_CFG_NODE_ID1- KAFKA_CFG_PROCESS_ROLESbroker,controller- KAFKA_CFG_CONTROLLER_QUORUM_VOTERS1kafka:9093# 监听配置- KAFKA_CFG_LISTENERSSASL_PLAINTEXT://:9092,CONTROLLER://:9093- KAFKA_CFG_ADVERTISED_LISTENERSSASL_PLAINTEXT://localhost:9092- KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAPCONTROLLER:PLAINTEXT,SASL_PLAINTEXT:SASL_PLAINTEXT- KAFKA_CFG_CONTROLLER_LISTENER_NAMESCONTROLLER# 集群ID- KAFKA_KRAFT_CLUSTER_ID4Zndq6u1TWqoaPt1AwHAKg# 客户端用户配置- KAFKA_CLIENT_USERSadmin,ttx- KAFKA_CLIENT_PASSWORDSTC4xaEvCSGaMuCZT,iri17ttx# controller 用户配置- KAFKA_CFG_SASL_MECHANISM_CONTROLLER_PROTOCOLPLAIN- KAFKA_CONTROLLER_USERadmin- KAFKA_CONTROLLER_PASSWORDTC4xaEvCSGaMuCZT# broker间通信用户配置- KAFKA_CFG_INTER_BROKER_LISTENER_NAMESASL_PLAINTEXT- KAFKA_CFG_SASL_MECHANISM_INTER_BROKER_PROTOCOLPLAIN- KAFKA_INTER_BROKER_USERadmin- KAFKA_INTER_BROKER_PASSWORDTC4xaEvCSGaMuCZT# 其他配置- KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLEtrue- ALLOW_PLAINTEXT_LISTENERyesrestart: unless-stoppedmkdir: cannot create directory /bitnami/kafka/config: Permission denied对容器的kafka用户进行授权
chown 1001:1001 /data/kafka/docker-compose down docker-compose up -d测试用户名密码连接
docker exec -it kafka shcat /tmp/client.properties EOF
security.protocolSASL_PLAINTEXT
sasl.mechanismPLAIN
sasl.jaas.configorg.apache.kafka.common.security.plain.PlainLoginModule required usernamettx passwordiri17ttx;
EOFkafka-topics.sh --create --topic test-topic --bootstrap-server localhost:9092 --command-config /tmp/client.properties --partitions 1 --replication-factor 1
kafka-topics.sh --list --bootstrap-server localhost:9092 --command-config /tmp/client.properties
