From 4551b7448ed04d2ca3e296d2802f611a22b1a725 Mon Sep 17 00:00:00 2001 From: ShiKhu Date: Wed, 10 Nov 2021 18:17:40 +0100 Subject: [PATCH] fix(backend-http): topic name --- backend/services/db/main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/backend/services/db/main.go b/backend/services/db/main.go index 49bb91938..d16512054 100644 --- a/backend/services/db/main.go +++ b/backend/services/db/main.go @@ -31,7 +31,7 @@ func main() { consumer := queue.NewMessageConsumer( env.String("GROUP_DB"), []string{ - env.String("TOPIC_IOS_RAW"), + env.String("TOPIC_RAW_IOS"), env.String("TOPIC_TRIGGER"), }, func(sessionID uint64, msg messages.Message, _ *types.Meta) {