Skip to content

Commit

Permalink
clippy
Browse files Browse the repository at this point in the history
  • Loading branch information
ameyc committed Sep 9, 2024
1 parent 7db9918 commit 40d09ce
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion examples/examples/emit_measurements.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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");
Expand Down
2 changes: 1 addition & 1 deletion examples/examples/simple_aggregation.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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());
Expand Down

0 comments on commit 40d09ce

Please sign in to comment.