Bug: Generated sink connector cannot be builded due to missing Stream::next impl

[EstebanBorai]

What happened

When generating a sink connector using the cdk generate subcommand,
the generated project cannot be builded due to a missing Stream::next
implementation.

Expected behavior

Generated connector can be builded out of the box.

Describe the setup

Fluvio: 0.11.8

How to reproduce it (as minimally and precisely as possible)

Steps to reproduce the behavior:

1. cdk generate
2. Choose sink for Which type of Connector would you like [source/sink]? prompt
3. Build with cdk deploy start --config ./sample-config.yaml

Log output

error[E0599]: no method named `next` found for type parameter `impl ConsumerStream` in the current scope
    --> src/main.rs:10:41
     |
8    | async fn start(config: CustomConfig, mut stream: impl ConsumerStream) -> Result<()> {
     |                                                  ------------------- method `next` not found for this type parameter
9    |     println!("Starting test-badconn sink connector with {config:?}");
10   |     while let Some(Ok(record)) = stream.next().await {
     |                                         ^^^^
     |
     = help: items from traits can only be used if the trait is in scope
help: there is a method `ne` with a similar name, but with different arguments
    --> /Users/esteban/.cargo/registry/src/index.crates.io-6f17d22bba15001f/async-std-1.12.0/src/stream/stream/mod.rs:2022:5
     |
2022 | /     fn ne<S>(
2023 | |        self,
2024 | |        other: S
2025 | |     ) -> NeFuture<Self, S>
...    |
2028 | |         S: Sized + Stream,
2029 | |         <Self as Stream>::Item: PartialEq<S::Item>,
     | |___________________________________________________^
help: the following traits which provide `next` are implemented but not in scope; perhaps you want to import one of them
     |
1    + use async_std::stream::stream::StreamExt;
     |
1    + use cranelift_codegen::isa::aarch64::lower::isle::generated_code::ContextIter;
     |
1    + use cranelift_codegen::opts::generated_code::ContextIter;
     |
1    + use futures_lite::stream::StreamExt;
     |
       and 5 other candidates

For more information about this error, try `rustc --explain E0599`.
error: could not compile `test-badconn` (bin "test-badconn") due to 1 previous error
   Compiling test-badconn v0.1.0 (/Users/esteban/Desktop/test-badconn)
error[E0599]: no method named `next` found for type parameter `impl ConsumerStream` in the current scope
    --> src/main.rs:10:41
     |
8    | async fn start(config: CustomConfig, mut stream: impl ConsumerStream) -> Result<()> {
     |                                                  ------------------- method `next` not found for this type parameter
9    |     println!("Starting test-badconn sink connector with {config:?}");
10   |     while let Some(Ok(record)) = stream.next().await {
     |                                         ^^^^
     |
     = help: items from traits can only be used if the trait is in scope
help: there is a method `ne` with a similar name, but with different arguments
    --> /Users/esteban/.cargo/registry/src/index.crates.io-6f17d22bba15001f/async-std-1.12.0/src/stream/stream/mod.rs:2022:5
     |
2022 | /     fn ne<S>(
2023 | |        self,
2024 | |        other: S
2025 | |     ) -> NeFuture<Self, S>
...    |
2028 | |         S: Sized + Stream,
2029 | |         <Self as Stream>::Item: PartialEq<S::Item>,
     | |___________________________________________________^
help: the following traits which provide `next` are implemented but not in scope; perhaps you want to import one of them
     |
1    + use async_std::stream::stream::StreamExt;
     |
1    + use cranelift_codegen::isa::aarch64::lower::isle::generated_code::ContextIter;
     |
1    + use cranelift_codegen::opts::generated_code::ContextIter;
     |
1    + use futures_lite::stream::StreamExt;
     |
       and 5 other candidates

For more information about this error, try `rustc --explain E0599`.
error: could not compile `test-badconn` (bin "test-badconn") due to 1 previous error
Error:

Environment (please complete the following information):

• OS: macOS
• Fluvio Version 0.11.8
• Kubernetes version: N/A
• Minikube or other k8 version (if used): N/A

Optional Debugging:

N/A

Additional context

N/A