From 4790729d2fa8aeac06990b414319970fb5d8c5bb Mon Sep 17 00:00:00 2001
From: Runji Wang <wangrunji0408@163.com>
Date: Mon, 1 Apr 2024 13:59:08 +0900
Subject: [PATCH] fix(connector): unblock `fetch_watermarks` in rdkafka
 (#15465)

Signed-off-by: Runji Wang <wangrunji0408@163.com>
Co-authored-by: wangrunji0408 <wangrunji0408@users.noreply.github.com>
---
 Cargo.lock | 8 ++++----
 Cargo.toml | 2 +-
 2 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index a92d371eeded..b0b4ea9fc8cb 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -5953,9 +5953,9 @@ dependencies = [
 
 [[package]]
 name = "madsim-rdkafka"
-version = "0.3.1+0.34.0"
+version = "0.3.4+0.34.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "79bf1f687bdd0146a72d6132478032d770ebe1dbe42e1f46799c4dcbd9b31cbc"
+checksum = "0992d46c19414bda24bad935ea223ad025dcd7e64f38f0acee388efa8ff5319b"
 dependencies = [
  "async-channel",
  "async-trait",
@@ -8209,9 +8209,9 @@ dependencies = [
 
 [[package]]
 name = "rdkafka-sys"
-version = "4.6.0+2.2.0"
+version = "4.7.0+2.3.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
-checksum = "ad63c279fca41a27c231c450a2d2ad18288032e9cbb159ad16c9d96eba35aaaf"
+checksum = "55e0d2f9ba6253f6ec72385e453294f8618e9e15c2c6aba2a5c01ccf9622d615"
 dependencies = [
  "cmake",
  "libc",
diff --git a/Cargo.toml b/Cargo.toml
index c519ad811ad6..50f44088ca75 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -108,7 +108,7 @@ aws-types = "1"
 etcd-client = { package = "madsim-etcd-client", version = "0.4" }
 futures-async-stream = "0.2.9"
 hytra = "0.1"
-rdkafka = { package = "madsim-rdkafka", version = "0.3.1", features = [
+rdkafka = { package = "madsim-rdkafka", version = "0.3.4", features = [
   "cmake-build",
 ] }
 hashbrown = { version = "0.14.0", features = [