From 0b57594ce037b8951ffdbad04e552660fefdfc45 Mon Sep 17 00:00:00 2001 From: Mark Haines Date: Tue, 15 Aug 2017 16:11:59 +0100 Subject: [PATCH] remember to call setupKafka() --- .../matrix-org/dendrite/cmd/dendrite-monolith-server/main.go | 1 + 1 file changed, 1 insertion(+) diff --git a/src/github.com/matrix-org/dendrite/cmd/dendrite-monolith-server/main.go b/src/github.com/matrix-org/dendrite/cmd/dendrite-monolith-server/main.go index fc6db0225..ee86469d3 100644 --- a/src/github.com/matrix-org/dendrite/cmd/dendrite-monolith-server/main.go +++ b/src/github.com/matrix-org/dendrite/cmd/dendrite-monolith-server/main.go @@ -81,6 +81,7 @@ func main() { m := newMonolith(cfg) m.setupDatabases() m.setupFederation() + m.setupKafka() m.setupRoomServer() m.setupProducers() m.setupNotifiers()