From 540c90a0f796ecb34e2585a44e21d31a87038e5f Mon Sep 17 00:00:00 2001 From: tabVersion Date: Mon, 29 Jan 2024 12:41:42 +0800 Subject: [PATCH 1/2] enabling pulsar compression --- src/connector/Cargo.toml | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/connector/Cargo.toml b/src/connector/Cargo.toml index 5231a55ea0583..2bf42bf38d81b 100644 --- a/src/connector/Cargo.toml +++ b/src/connector/Cargo.toml @@ -92,6 +92,8 @@ pulsar = { version = "6.1", default-features = false, features = [ "tokio-runtime", "telemetry", "auth-oauth2", + "lz4", + "zstd", ] } rdkafka = { workspace = true, features = [ "cmake-build", From 9cf25039b6e0d908b1ffea249355fa190c21e416 Mon Sep 17 00:00:00 2001 From: tabVersion Date: Mon, 29 Jan 2024 12:44:27 +0800 Subject: [PATCH 2/2] fix --- Cargo.lock | 2 ++ 1 file changed, 2 insertions(+) diff --git a/Cargo.lock b/Cargo.lock index c3af1be34d497..6efcc6c328c17 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -7997,6 +7997,7 @@ dependencies = [ "futures-io", "futures-timer", "log", + "lz4", "native-tls", "nom", "oauth2", @@ -8015,6 +8016,7 @@ dependencies = [ "tracing", "url", "uuid", + "zstd 0.12.4", ] [[package]]