Name: slowwildws-api Host: 0.0.0.0 Port: 9999 MaxConnectionIdle: 300 MsgChatTransfer: Topic: msgChatTransfer Addrs: - 121.11.99.220:19094 MsgReadTransfer: Topic: msgReadTransfer Addrs: - 121.11.99.220:19094 MsgPushToClientTransfer: # service的名称 Name: MsgSendConsumer # kafka 的多个 Broker 节点 Brokers: - 121.11.99.220:19094 # 消费者组 Group: kafka # 订阅的 Topic 主题 Topic: msgPushToClientTransfer # 从头开始消费 Offset: first # go-queue 内部是起多个 goroutine 从 kafka 中获取信息写入进程内的 channel,这个参数是控制此处的 goroutine 数量(⚠️ 并不是真正消费时的并发 goroutine 数量) Consumers: 2