feat(sink): ProtoEncoder and AvroEncoder

risingwavelabs · Oct 11, 2023 · 2717d5b · 2717d5b
1 parent 9db52aa
commit 2717d5b
Show file tree

Hide file tree

Showing 7 changed files with 1,420 additions and 5 deletions.
diff --git a/src/connector/Cargo.toml b/src/connector/Cargo.toml
@@ -83,6 +83,7 @@ paste = "1"
 prometheus = { version = "0.13", features = ["process"] }
 prost = { version = "0.12", features = ["no-recursion-limit"] }
 prost-reflect = "0.12"
+prost-types = "0.12"
 protobuf-native = "0.2.1"
 pulsar = { version = "6.0", default-features = false, features = [
     "tokio-runtime",
@@ -138,7 +139,6 @@ workspace-hack = { path = "../workspace-hack" }
 
 [dev-dependencies]
 criterion = { workspace = true, features = ["async_tokio", "async"] }
-prost-types = "0.12"
 rand = "0.8"
 tempfile = "3"
 tracing-test = "0.2"

diff --git a/src/connector/src/lib.rs b/src/connector/src/lib.rs
@@ -32,6 +32,7 @@
 #![feature(impl_trait_in_assoc_type)]
 #![feature(iter_from_generator)]
 #![feature(if_let_guard)]
+#![feature(iterator_try_collect)]
 
 use std::time::Duration;