From 20ac00a6dadc7309d87f2787247b72739e06087d Mon Sep 17 00:00:00 2001
From: Bohan Zhang <tabvision@bupt.icu>
Date: Mon, 29 Jan 2024 13:40:12 +0800
Subject: [PATCH] feat: enabling pulsar compression `lz4` (#14833)

---
 Cargo.lock               | 2 ++
 src/connector/Cargo.toml | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/Cargo.lock b/Cargo.lock
index ef81545baae68..8b2d83d9157c7 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]]
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",