slowwildws-api.yaml 719 B

12345678910111213141516171819202122232425262728
  1. Name: slowwildws-api
  2. Host: 0.0.0.0
  3. Port: 9999
  4. MaxConnectionIdle: 300
  5. MsgChatTransfer:
  6. Topic: msgChatTransfer
  7. Addrs:
  8. - 121.11.99.220:19094
  9. MsgReadTransfer:
  10. Topic: msgReadTransfer
  11. Addrs:
  12. - 121.11.99.220:19094
  13. MsgPushToClientTransfer:
  14. # service的名称
  15. Name: MsgSendConsumer
  16. # kafka 的多个 Broker 节点
  17. Brokers:
  18. - 121.11.99.220:19094
  19. # 消费者组
  20. Group: kafka
  21. # 订阅的 Topic 主题
  22. Topic: msgPushToClientTransfer
  23. # 从头开始消费
  24. Offset: first
  25. # go-queue 内部是起多个 goroutine 从 kafka 中获取信息写入进程内的 channel,这个参数是控制此处的 goroutine 数量(⚠️ 并不是真正消费时的并发 goroutine 数量)
  26. Consumers: 2