chore: configure test kafka queue

This commit is contained in:
richjohnrambo
2026-08-28 00:35:10 +08:00
parent 33bf0f8625
commit 8c54914f9a
+6 -6
View File
@@ -192,7 +192,7 @@ token:
# 消息队列
queue:
switch: true # 队列开关,可选:true|false,默认为true
driver: "$QUEUE_DRIVER" # 队列驱动,可选:disk|redis|rocketmq|kafka,默认为disk
driver: "kafka" # 队列驱动,可选:disk|redis|rocketmq|kafka,默认为disk
groupName: "hotgo" # mq群组名称
# 磁盘队列
disk:
@@ -212,11 +212,11 @@ queue:
retry: 0 # 重试次数
logLevel: "info" # rocketmq日志输出级别,可选:all|close|debug|info|warn|error|fatal
kafka:
address: ["$KAFKA_ADDRESS"] # kafka地址+端口
version: "$KAFKA_VERSION" # kafka专属配置,默认2.4.0.0
username: "$KAFKA_USERNAME" # SASL用户名,未开启认证时留空
password: "$KAFKA_PASSWORD" # SASL密码,未开启认证时留空
mechanism: "$KAFKA_SASL_MECHANISM" # SASL机制,可选:SCRAM-SHA-512|SCRAM-SHA-256
address: ["64.118.137.182:9094"] # kafka地址+端口
version: "2.4.0.0" # kafka专属配置,默认2.4.0.0
username: "kafka-external" # SASL用户名,未开启认证时留空
password: "gr58tNnlZOVGW3AmMbL2" # SASL密码,未开启认证时留空
mechanism: "SCRAM-SHA-512" # SASL机制,可选:SCRAM-SHA-512|SCRAM-SHA-256
randClient: true # 开启随机生成clientID,可以实现启动多实例同时一起消费相同topic,加速消费能力的特性,默认为true
multiConsumer: true # 是否支持创建多个消费者