bump

Signed-off-by: xxchan <[email protected]>
risingwavelabs · Jan 15, 2025 · c74bc2c · c74bc2c
1 parent d94a20b
commit c74bc2c
Show file tree

Hide file tree

Showing 3 changed files with 16 additions and 51 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -140,9 +140,9 @@ axum = "=0.7.4" # TODO: 0.7.5+ does not work with current toolchain
 axum-extra = "0.9"
 futures-async-stream = "0.2.9"
 hytra = "0.1"
-rdkafka = { package = "madsim-rdkafka", version = "0.4.1", features = [
+rdkafka = { package = "madsim-rdkafka", version = "0.4.3", features = [
     "cmake-build",
-], git = "https://github.com/xxchan/madsim", rev = "d2b9fbb0bb2dfbc4f205a11ed1f2d9e8da52307e" }
+] }
 hashbrown = { version = "0.14", features = ["ahash", "inline-more", "nightly"] }
 criterion = { version = "0.5", features = ["async_futures"] }
 tonic = { package = "madsim-tonic", version = "0.5.1" }

diff --git a/src/connector/src/source/base.rs b/src/connector/src/source/base.rs
@@ -205,6 +205,7 @@ pub type SourceEnumeratorContextRef = Arc<SourceEnumeratorContext>;
 #[async_trait]
 pub trait AnySplitEnumerator: Send {
     async fn list_splits(&mut self) -> Result<Vec<SplitImpl>>;
+    async fn on_drop_fragments(&mut self, _fragment_ids: Vec<u32>) -> Result<()>;
 }
 
 #[async_trait]
@@ -214,6 +215,10 @@ impl<T: SplitEnumerator<Split: Into<SplitImpl>>> AnySplitEnumerator for T {
             .await
             .map(|s| s.into_iter().map(|s| s.into()).collect())
     }
+
+    async fn on_drop_fragments(&mut self, _fragment_ids: Vec<u32>) -> Result<()> {
+        SplitEnumerator::on_drop_fragments(self, _fragment_ids).await
+    }
 }
 
 /// The max size of a chunk yielded by source stream.