From 00ee6663785fc64633d987d65a709597370bcaa0 Mon Sep 17 00:00:00 2001
From: xxchan <xxchan22f@gmail.com>
Date: Wed, 11 Dec 2024 00:59:28 +0800
Subject: [PATCH] test: workaround a flaky source test (#19729)

Signed-off-by: xxchan <xxchan22f@gmail.com>
---
 e2e_test/source_inline/kafka/issue_19563.slt.serial | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/e2e_test/source_inline/kafka/issue_19563.slt.serial b/e2e_test/source_inline/kafka/issue_19563.slt.serial
index 528fac0735767..cb3986f934df4 100644
--- a/e2e_test/source_inline/kafka/issue_19563.slt.serial
+++ b/e2e_test/source_inline/kafka/issue_19563.slt.serial
@@ -46,6 +46,10 @@ select array_length(upstream_fragment_ids) from rw_fragments where array_contain
 ----
 3
 
+# XXX: wait until source reader is ready. then produce data.
+# This is a temporary workaround for a data loss bug https://github.com/risingwavelabs/risingwave/issues/19681#issuecomment-2532183002
+sleep 2s
+
 system ok
 cat <<EOF | rpk topic produce test-topic-19563
 {"v1": "3031-01-01 19:00:00"}
@@ -70,4 +74,4 @@ statement ok
 DROP SOURCE kafkasource CASCADE;
 
 system ok
-rpk topic delete test-topic-18308
+rpk topic delete test-topic-19563