fix

risingwavelabs · Mar 12, 2024 · 287d40f · 287d40f
1 parent c55b13d
commit 287d40f
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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"
             )));