diff --git a/src/lib/processors/watch-processor.ts b/src/lib/processors/watch-processor.ts
index 80b40b3b..3698460f 100644
--- a/src/lib/processors/watch-processor.ts
+++ b/src/lib/processors/watch-processor.ts
@@ -147,7 +147,7 @@ async function runBinding(
   };
 
   // Setup the resource watch
-  const watcher = K8s(binding.model, binding.filters).Watch(async (obj, phase) => {
+  const watcher = K8s(binding.model, { ...binding.filters, kindOverride: binding.kind }).Watch(async (obj, phase) => {
     Log.debug(obj, `Watch event ${phase} received`);
 
     if (binding.isQueue) {