Name: slowwild Host: 0.0.0.0 Port: 8080 ListenOn: 0.0.0.0:8080 Etcd: Hosts: - 121.11.99.220:3379 User: root Pass: huang1205@@ Key: slowwildserver DB: DataSource: root:easy-chat@tcp(121.11.99.220:13306)/slow_wild?charset=utf8mb4&parseTime=True&loc=Local RedisConf: Host: 121.11.99.220:16379 Password: "" DB: 0 # 消息推送到客户端的topic MsgPushToClientTransfer: Topic: msgPushToClientTransfer Addrs: - 121.11.99.220:19094 # 用户消息消费配置,这里是采用go-zero自带的kafka配置,可以参考https://go-zero.dev/docs/tutorials/message-queue/kafka MsgChatTransfer: # service的名称 Name: MsgChatTransfer # kafka 的多个 Broker 节点 Brokers: - 121.11.99.220:19094 # 消费者组 Group: kafka # 订阅的 Topic 主题 Topic: msgChatTransfer # 从头开始消费 Offset: first # go-queue 内部是起多个 goroutine 从 kafka 中获取信息写入进程内的 channel,这个参数是控制此处的 goroutine 数量(⚠️ 并不是真正消费时的并发 goroutine 数量) Consumers: 1 #mongo配置 Mongo: Url: "mongodb://root:123456@121.11.99.220:47017" Db: easy-chat Collection: easy-chat-collection # 消息已读处理的配置 MsgReadHandler: GroupMsgReadHandler: 1 GroupMsgReadRecordDelayTime: 60 GroupMsgReadRecordDelayCount: 2