diff --git a/examples/examples/emit_measurements.rs b/examples/examples/emit_measurements.rs
index d4df6e5..749a2d4 100644
--- a/examples/examples/emit_measurements.rs
+++ b/examples/examples/emit_measurements.rs
@@ -18,7 +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/simple_aggregation.rs b/examples/examples/simple_aggregation.rs
index 7185b8d..a0bb20f 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());