Cassandra Sink: set 2 resource units in all the examples (LangStream#342

)
vectorize-io · Sep 5, 2023 · 6f2adcc · 6f2adcc
1 parent 87c343c
commit 6f2adcc
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 0 deletions.
diff --git a/examples/applications/kafka-connect/pipeline.yaml b/examples/applications/kafka-connect/pipeline.yaml
@@ -22,6 +22,8 @@ pipeline:
   - name: "Write to Cassandra"
     type: "sink"
     input: "input-topic"
+    resources:
+      size: 2
     configuration:
       connector.class: com.datastax.oss.kafka.sink.CassandraSinkConnector
       key.converter: org.apache.kafka.connect.storage.StringConverter

diff --git a/examples/applications/text-processing/write-to-astra.yaml b/examples/applications/text-processing/write-to-astra.yaml
@@ -22,6 +22,8 @@ pipeline:
   - name: "Write to AstraDB"
     type: "sink"
     input: "chunks-topic"
+    resources:
+      size: 2
     configuration:
       connector.class: com.datastax.oss.kafka.sink.CassandraSinkConnector
       key.converter: org.apache.kafka.connect.storage.StringConverter

diff --git a/examples/applications/webcrawler-source/write-to-astra.yaml b/examples/applications/webcrawler-source/write-to-astra.yaml
@@ -22,6 +22,8 @@ pipeline:
   - name: "Write to AstraDB"
     type: "sink"
     input: "chunks-topic"
+    resources:
+       size: 2
     configuration:
       connector.class: com.datastax.oss.kafka.sink.CassandraSinkConnector
       key.converter: org.apache.kafka.connect.storage.StringConverter

diff --git a/langstream-e2e-tests/src/test/resources/apps/cassandra-sink/pipeline.yaml b/langstream-e2e-tests/src/test/resources/apps/cassandra-sink/pipeline.yaml
@@ -24,6 +24,8 @@ pipeline:
   - name: "Write to Cassandra"
     type: "sink"
     input: "TEST_TOPIC_C1"
+    resources:
+      size: 2
     configuration:
       connector.class: com.datastax.oss.kafka.sink.CassandraSinkConnector
       key.converter: org.apache.kafka.connect.storage.StringConverter