diff --git a/pkg/factories/datastream/table.go b/pkg/factories/datastream/table.go
index 23bd5c1..9bbf599 100644
--- a/pkg/factories/datastream/table.go
+++ b/pkg/factories/datastream/table.go
@@ -49,7 +49,7 @@ func TableDatastreamFunc(dynamicClient *dynamic.DynamicClient, restMapper meta.R
 		)
 
 		inf := infFact.ForResource(mapping.Resource)
-		inf.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
+		_, err = inf.Informer().AddEventHandler(cache.ResourceEventHandlerFuncs{
 			AddFunc: func(obj interface{}) {
 				u := obj.(*unstructured.Unstructured)
 				table.AddOrUpdate(u)
@@ -64,6 +64,10 @@ func TableDatastreamFunc(dynamicClient *dynamic.DynamicClient, restMapper meta.R
 			},
 		})
 
+		if err != nil {
+			return nil, err
+		}
+
 		table.SetLister(inf.Lister())
 		table.SetScope(mapping.Scope.Name())
 		return inf.Informer(), nil