Home Explore Help
Register Sign In
Client
/
ylink
5
0
Fork 0
Files Issues 0 Pull Requests 0 Wiki
Browse Source

v0.0.1开发：接入kafka消息中间件

#Suyghur 2 years ago
parent
824e2f1a34
commit
9279fe45e0
17 changed files with 459 additions and 89 deletions
Split View Show Diff Stats
  1. 6 0
      bff/rpcbff/rpc/etc/rpcbff.yaml
  2. 6 2
      bff/rpcbff/rpc/internal/config/config.go
  3. 54 0
      bff/rpcbff/rpc/internal/ext/consumerhandler.go
  4. 4 0
      bff/rpcbff/rpc/internal/svc/servicecontext.go
  5. 6 0
      core/cmd/rpc/etc/cmd.yaml
  6. 5 1
      core/cmd/rpc/internal/config/config.go
  7. 26 1
      core/cmd/rpc/internal/logic/playersendmsglogic.go
  8. 8 3
      core/cmd/rpc/internal/svc/servicecontext.go
  9. 94 5
      docker-compose-env.yml
  10. 50 0
      ext/kafka/consumergroup.go
  11. 11 0
      ext/kafka/kqconfig.go
  12. 72 0