From fc51f72bf9a861f9c1ab4ca1ea497eeedfbdaeb0 Mon Sep 17 00:00:00 2001 From: Richard van der Hoff Date: Thu, 31 Aug 2017 12:27:53 +0100 Subject: [PATCH] Avoid swallowing error from kafka (#203) --- .../matrix-org/dendrite/cmd/dendrite-monolith-server/main.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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 25b269b8..8cc1ccbb 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 @@ -282,7 +282,7 @@ func (m *monolith) setupConsumers() { m.cfg, m.kafkaConsumer(), m.accountDB, m.queryAPI, ) if err = clientAPIConsumer.Start(); err != nil { - log.Panicf("startup: failed to start room server consumer") + log.Panicf("startup: failed to start room server consumer: %s", err) } syncAPIRoomConsumer := syncapi_consumers.NewOutputRoomEvent(