Avoid swallowing error from kafka (#203)

main
Richard van der Hoff 2017-08-31 12:27:53 +01:00 committed by Mark Haines
parent 2183712e04
commit fc51f72bf9
1 changed files with 1 additions and 1 deletions

View File

@ -282,7 +282,7 @@ func (m *monolith) setupConsumers() {
m.cfg, m.kafkaConsumer(), m.accountDB, m.queryAPI, m.cfg, m.kafkaConsumer(), m.accountDB, m.queryAPI,
) )
if err = clientAPIConsumer.Start(); err != nil { 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( syncAPIRoomConsumer := syncapi_consumers.NewOutputRoomEvent(