From 287d40f9895963a2190acdcec369db31771c25ec Mon Sep 17 00:00:00 2001 From: xxchan Date: Tue, 12 Mar 2024 16:07:23 +0800 Subject: [PATCH] fix --- src/frontend/src/catalog/connection_catalog.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/frontend/src/catalog/connection_catalog.rs b/src/frontend/src/catalog/connection_catalog.rs index 7239b72c0d17..54e1210979fe 100644 --- a/src/frontend/src/catalog/connection_catalog.rs +++ b/src/frontend/src/catalog/connection_catalog.rs @@ -71,7 +71,7 @@ pub(crate) fn resolve_private_link_connection( ) -> Result<()> { #[allow(irrefutable_let_patterns)] if let connection::Info::PrivateLinkService(svc) = &connection.info { - if properties.is_kafka_connector() { + if !properties.is_kafka_connector() { return Err(RwError::from(anyhow!( "Private link is only supported for Kafka connector" )));