Removed wrong panic (#1183)

Signed-off-by: Francesco Guardiani <francescoguard@gmail.com>
knative · Apr 30, 2020 · 48a9bd1 · 48a9bd1
1 parent 7a222bd
commit 48a9bd1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/channel/pkg/dispatcher/dispatcher.go b/kafka/channel/pkg/dispatcher/dispatcher.go
@@ -332,7 +332,7 @@ func (d *KafkaDispatcher) subscribe(channelRef eventingchannels.ChannelReference
 	// this goroutine logs errors incoming
 	go func() {
 		for err = range consumerGroup.Errors() {
-			panic(err)
+			d.logger.Warn("Error in consumer group", zap.Error(err))
 		}
 	}()