feat kafka

2026-01-23 21:26:07 +08:00
parent c0f6cd90c6
commit 3b36244282
4 changed files with 78 additions and 10 deletions
--- a/app/app.go
+++ b/app/app.go
@@ -22,7 +22,7 @@ func (p *Program) Init(_ svc.Environment) error {
 		return err
 	}
 	p.moduleList = append(p.moduleList, base)
-	p.moduleList = append(p.moduleList, (&module.DB{}).Bind(config.Get().DB))
+	p.moduleList = append(p.moduleList, (&module.DB{}).Bind(config.Get().DB, common.KeyDiscoverServiceNameGateway))
 	p.moduleList = append(p.moduleList, &ModuleWebServer{})
 	p.moduleList = append(p.moduleList, &ModuleWebsocketServer{})
 	p.moduleList = append(p.moduleList, &ModuleLoginQueue{})