WIP

aklivity · Oct 18, 2024 · 4704dda · 4704dda
1 parent 9af3f60
commit 4704dda
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/.../io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java b/.../io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java
@@ -67,7 +67,7 @@
 
 public final class RisingwaveProxyFactory implements RisingwaveStreamFactory
 {
-    private static final String SPLIT_STATEMENTS = "(?<=;)(?!\\x00)";
+    private static final String SPLIT_STATEMENTS = "(?<=;)(?!\\s*\\x00)";
     private static final int END_OF_FIELD = 0x00;
 
     private static final int FLAGS_INIT = 0x02;