Remove unreachable panic

heetch · Jun 12, 2019 · 3327d2b · 3327d2b
1 parent a1817eb
commit 3327d2b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/consumer/consumer.go b/consumer/consumer.go
@@ -239,7 +239,8 @@ func (c *Consumer) handleMsg(msg *sarama.ConsumerMessage) (*Message, int) {
 		}
 		return m, attempts
 	}
-	panic("unreachable")
+	return nil, attempts
+
 }
 
 // MetricsReporter is an interface that can be passed to set metrics hook to receive metrics