kafka.go 884 B

12345678910111213141516171819202122232425262728293031323334353637383940
  1. package main
  2. import (
  3. "context"
  4. "flag"
  5. "fmt"
  6. "github.com/zeromicro/go-zero/core/service"
  7. "microGame/app/mq/cmd/kafka/internal/mqs"
  8. "microGame/app/mq/cmd/kafka/internal/config"
  9. "microGame/app/mq/cmd/kafka/internal/svc"
  10. "github.com/zeromicro/go-zero/core/conf"
  11. "github.com/zeromicro/go-zero/rest"
  12. )
  13. var configFile = flag.String("f", "etc/kafka-api.yaml", "the config file")
  14. func main() {
  15. flag.Parse()
  16. var c config.Config
  17. conf.MustLoad(*configFile, &c)
  18. server := rest.MustNewServer(c.RestConf)
  19. defer server.Stop()
  20. svcCtx := svc.NewServiceContext(c)
  21. // handler.RegisterHandlers(server, svcCtx)
  22. ctx := context.Background()
  23. serviceGroup := service.NewServiceGroup()
  24. defer serviceGroup.Stop()
  25. for _, mq := range mqs.Consumers(c, ctx, svcCtx) {
  26. serviceGroup.Add(mq)
  27. }
  28. fmt.Printf("Starting kafka server at %s:%d...\n", c.Host, c.Port)
  29. serviceGroup.Start()
  30. }