fix(cdk): sink generation for conns fails to build (#4005)

infinyon · May 12, 2024 · 5a1ab22 · 5a1ab22
1 parent 5b0b140
commit 5a1ab22
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/connector/cargo_template/Cargo.toml.liquid b/connector/cargo_template/Cargo.toml.liquid
@@ -5,6 +5,8 @@ authors = ["{{authors}}"]
 edition = "2021"
 
 [dependencies]
-fluvio = { git = "https://github.com/infinyon/fluvio", rev = "{{fluvio-cargo-dependency-hash}}" }
-fluvio-connector-common = { git = "https://github.com/infinyon/fluvio", rev = "{{fluvio-cargo-dependency-hash}}", features = ["derive"]}
+{% if connector-type == "sink" %}futures = { version = "0.3", default-features = false }{% endif %}
 serde = { version = "1.0", default-features = false, features = ["derive"]}
+
+fluvio = { git = "https://github.com/infinyon/fluvio", rev = "{{fluvio-cargo-dependency-hash}}" }
+fluvio-connector-common = { git = "https://github.com/infinyon/fluvio", rev = "{{fluvio-cargo-dependency-hash}}", features = ["derive"] }
diff --git a/connector/cargo_template/src/main.rs b/connector/cargo_template/src/main.rs
@@ -21,6 +21,8 @@ async fn start(config: CustomConfig, producer: TopicProducer) -> Result<()> {
 }
 
 {% elsif connector-type == "sink" %}
+use futures::StreamExt;
+
 use fluvio_connector_common::{connector, consumer::ConsumerStream, Result};
 
 #[connector(sink)]