From eea3a7d6cf001ffcb65e6bc91c85476fe73a7735 Mon Sep 17 00:00:00 2001
From: Paul-Christian Volkmer <code@pcvolkmer.de>
Date: Sat, 6 Sep 2025 13:00:44 +0200
Subject: [PATCH] refactor: remove expect()

---
 src/main.rs | 8 +++-----
 1 file changed, 3 insertions(+), 5 deletions(-)

diff --git a/src/main.rs b/src/main.rs
index e8bf28e..982f362 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -118,8 +118,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
         .set("auto.offset.reset", "earliest")
         .set("enable.auto.commit", "false")
         .set_log_level(RDKafkaLogLevel::Debug)
-        .create()
-        .expect("Kafka consumer created");
+        .create()?;
 
     let topic: &str = &CONFIG.topic.clone();
 
@@ -130,10 +129,9 @@ async fn main() -> Result<(), Box<dyn Error>> {
     let mut producer_client_config = client_config();
 
     let producer: &FutureProducer = &producer_client_config
-        .set("bootstrap.servers", &CONFIG.bootstrap_servers.to_string())
+        .set("bootstrap.servers", &CONFIG.bootstrap_servers)
         .set("message.timeout.ms", "5000")
-        .create()
-        .expect("Producer creation error");
+        .create()?;
 
     while let Ok(msg) = consumer.recv().await {
         match msg.payload_view::<str>() {