diff --git a/logs/watcher.go b/logs/watcher.go
index d6b3e78..3fb3253 100644
--- a/logs/watcher.go
+++ b/logs/watcher.go
@@ -134,6 +134,10 @@ func (w *Watcher) Watch(ctx context.Context) error {
 				w.watchResource(ctx, resource.GetUID(), labels.SelectorFromSet(selectorAsMap))
 			case watch.Deleted:
 				w.unwatchResource()
+			case watch.Error:
+				err := evt.Object.(error)
+				// TODO: remove panic and handle error
+				panic(err)
 			}
 		// errChan is never closed.
 		case err := <-w.errChan: