From 007918e35b2749adf08561b68197a5753292a3a9 Mon Sep 17 00:00:00 2001 From: Amey Chaugule Date: Mon, 2 Sep 2024 14:11:26 -0700 Subject: [PATCH] rv kafka settings --- examples/examples/emit_measurements.rs | 5 +---- examples/examples/kafka_rideshare.rs | 2 +- examples/examples/simple_aggregation.rs | 2 +- 3 files changed, 3 insertions(+), 6 deletions(-) diff --git a/examples/examples/emit_measurements.rs b/examples/examples/emit_measurements.rs index 94e5976..749a2d4 100644 --- a/examples/examples/emit_measurements.rs +++ b/examples/examples/emit_measurements.rs @@ -18,10 +18,7 @@ async fn main() -> Result<()> { let mut tasks = tokio::task::JoinSet::new(); let producer: FutureProducer = ClientConfig::new() - .set( - "bootstrap.servers", - String::from("localhost:19092,localhost:29092,localhost:39092"), - ) + .set("bootstrap.servers", String::from("localhost:9092")) .set("message.timeout.ms", "100") .create() .expect("Producer creation error"); diff --git a/examples/examples/kafka_rideshare.rs b/examples/examples/kafka_rideshare.rs index 1c24e29..b520a7b 100644 --- a/examples/examples/kafka_rideshare.rs +++ b/examples/examples/kafka_rideshare.rs @@ -49,7 +49,7 @@ async fn main() -> Result<()> { } }"#; - let bootstrap_servers = String::from("localhost:19092,localhost:29092,localhost:39092"); + let bootstrap_servers = String::from("localhost:9092"); let ctx = Context::new()?; diff --git a/examples/examples/simple_aggregation.rs b/examples/examples/simple_aggregation.rs index 15f39e3..3c5228c 100644 --- a/examples/examples/simple_aggregation.rs +++ b/examples/examples/simple_aggregation.rs @@ -20,7 +20,7 @@ async fn main() -> Result<()> { let sample_event = get_sample_json(); - let bootstrap_servers = String::from("localhost:19092,localhost:29092,localhost:39092"); + let bootstrap_servers = String::from("localhost:9092"); let ctx = Context::new()?; let mut topic_builder = KafkaTopicBuilder::new(bootstrap_servers.clone());