diff --git a/src/stream/src/from_proto/sink.rs b/src/stream/src/from_proto/sink.rs index bc19c316cb09e..2a5da8d88df73 100644 --- a/src/stream/src/from_proto/sink.rs +++ b/src/stream/src/from_proto/sink.rs @@ -332,7 +332,7 @@ struct JdbcUrl { } fn parse_jdbc_url(url: &str) -> anyhow::Result { - if url.starts_with("jdbc:postgresql") { + if !url.starts_with("jdbc:postgresql") { bail!("invalid jdbc url, to switch to postgres rust connector, we need to use the url jdbc:postgresql://...") }