diff --git a/deploy/dev/kafka.yaml b/deploy/dev/kafka.yaml
index 5fd9089..4af7499 100644
--- a/deploy/dev/kafka.yaml
+++ b/deploy/dev/kafka.yaml
@@ -23,7 +23,6 @@ metadata:
   namespace: kafka
 spec:
   kafka:
-    version: 3.6.1
     replicas: 1
     listeners:
       - name: plain
diff --git a/hoptimator-catalog/src/main/java/com/linkedin/hoptimator/catalog/ResourceProvider.java b/hoptimator-catalog/src/main/java/com/linkedin/hoptimator/catalog/ResourceProvider.java
index 1ba8f5f..f84a958 100644
--- a/hoptimator-catalog/src/main/java/com/linkedin/hoptimator/catalog/ResourceProvider.java
+++ b/hoptimator-catalog/src/main/java/com/linkedin/hoptimator/catalog/ResourceProvider.java
@@ -70,7 +70,8 @@ default ResourceProvider toAll(ResourceProvider sink) {
       // link all sources to all sinks       
       sink.resources(x).forEach(y -> {
         combined.add(new Resource(y) {{
-          if (!(y instanceof ReadResource || y instanceof WriteResource)) {
+          if (!(y instanceof ReadResource || y instanceof WriteResource)
+              && y.inputs().isEmpty()) {
             sources.forEach(z -> input(z));
           }
         }});