From 1fc90f49db625711d953a2c76c6970b68ab94703 Mon Sep 17 00:00:00 2001
From: David Kornel <kornys@outlook.com>
Date: Mon, 16 Sep 2024 16:47:05 +0200
Subject: [PATCH] Send more messages in sql filter test

Signed-off-by: David Kornel <kornys@outlook.com>
---
 src/test/java/io/streams/e2e/flink/sql/SqlJobRunnerST.java | 2 +-
 1 file changed, 1 insertion(+), 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
index ba97602..c48eb29 100644
--- 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(