diff --git a/example-projects/rdkafka-example/Cargo.toml b/example-projects/rdkafka-example/Cargo.toml index 6972df7..dce2373 100644 --- a/example-projects/rdkafka-example/Cargo.toml +++ b/example-projects/rdkafka-example/Cargo.toml @@ -19,5 +19,7 @@ tokio = { version = "^0.2", features = ["full"] } clap = "2.33.1" [dependencies.rdkafka] -version = "~0.23" -features = ["ssl", "sasl"] \ No newline at end of file +version = "^0.24" +features = ["cmake-build"] + +[workspace] diff --git a/example-projects/rdkafka-example/src/main.rs b/example-projects/rdkafka-example/src/main.rs index 0306171..7e1c138 100644 --- a/example-projects/rdkafka-example/src/main.rs +++ b/example-projects/rdkafka-example/src/main.rs @@ -9,6 +9,7 @@ use rdkafka::config::{ClientConfig, RDKafkaLogLevel}; use rdkafka::consumer::stream_consumer::StreamConsumer; use rdkafka::consumer::{CommitMode, Consumer, DefaultConsumerContext}; use rdkafka::producer::{FutureProducer, FutureRecord}; +use std::time::Duration; // You need a running Kafka cluster to try out this example. // With docker: docker run --rm --net=host -e ADV_HOST=localhost -e SAMPLEDATA=0 lensesio/fast-data-dev @@ -78,7 +79,7 @@ async fn produce(brokers: &str, topic_name: &str) { FutureRecord::to(topic_name) .message_record(&message_record) .key(&format!("Key {}", i)), - 0, + Duration::from_secs(10), ) .await;