broker: check err

travisjeffery · Dec 6, 2016 · f742237 · f742237
1 parent 222cc90
commit f742237
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/broker/broker.go b/broker/broker.go
@@ -297,7 +297,9 @@ func (s *Broker) Apply(l *raft.Log) interface{} {
 		if err := json.Unmarshal(b, p); err != nil {
 			panic(errors.Wrap(err, "json unmarshal failed"))
 		}
-		s.deleteTopic(p)
+		if err := s.deleteTopic(p); err != nil {
+			panic(errors.Wrap(err, "topic delete failed"))
+		}
 	}
 	return nil
 }