Send more messages in sql filter test

Signed-off-by: David Kornel <[email protected]>
streamshub · Sep 16, 2024 · 1fc90f4 · 1fc90f4
1 parent de7a492
commit 1fc90f4
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/test/java/io/streams/e2e/flink/sql/SqlJobRunnerST.java b/src/test/java/io/streams/e2e/flink/sql/SqlJobRunnerST.java
@@ -96,7 +96,7 @@ void testFlinkSqlRunnerSimpleFilter() {
             .withNamespaceName(namespace)
             .withTopicName("flink.payment.data")
             .withBootstrapAddress(bootstrapServer)
-            .withMessageCount(2000)
+            .withMessageCount(10000)
             .withDelayMs(10)
             .withMessageTemplate("payment_fiat")
             .withAdditionalConfig(