diff --git a/incubator/binding-risingwave/src/main/java/io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java b/incubator/binding-risingwave/src/main/java/io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java index c42985b4f4..3883a4ce1b 100644 --- a/incubator/binding-risingwave/src/main/java/io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java +++ b/incubator/binding-risingwave/src/main/java/io/aklivity/zilla/runtime/binding/risingwave/internal/stream/RisingwaveProxyFactory.java @@ -97,7 +97,7 @@ public final class RisingwaveProxyFactory implements RisingwaveStreamFactory private static final String SEVERITY_WARNING = "WARNING\u0000"; private static final String CODE_XX000 = "XX000\u0000"; - private static final int STRING_TYPE_OID = 1043; + private static final int VARCHAR_TYPE_OID = 1043; private static final String POSTGRES_USER = "postgres\u0000"; private static final String DEFAULT_USER = "default\u0000"; @@ -830,7 +830,7 @@ public void doDescription( .name("%s\u0000".formatted(name)) .tableOid(0) .index((short) 0) - .typeOid(STRING_TYPE_OID) + .typeOid(VARCHAR_TYPE_OID) .length((short) name.length()) .modifier(-1) .format(f -> f.set(PgsqlFormat.TEXT))