pcvolkmer/mv64e-kafka-to-rest-gateway
1
0
Fork 0
mirror of https://github.com/pcvolkmer/mv64e-kafka-to-rest-gateway synced 2025-09-13 09:12:52 +00:00
Code Activity

refactor: remove expect()

Browse Source
This commit is contained in:
Paul-Christian Volkmer
2025-09-06 13:00:44 +02:00
parent d27c8276fe
commit eea3a7d6cf
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main.rs
View File

@@ -118,8 +118,7 @@ async fn main() -> Result<(), Box<dyn Error>> {
.set("auto.offset.reset", "earliest") .set("auto.offset.reset", "earliest")
.set("enable.auto.commit", "false") .set("enable.auto.commit", "false")
.set_log_level(RDKafkaLogLevel::Debug) .set_log_level(RDKafkaLogLevel::Debug)
.create() .create()?;
.expect("Kafka consumer created");
let topic: &str = &CONFIG.topic.clone(); 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 mut producer_client_config = client_config();
let producer: &FutureProducer = &producer_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") .set("message.timeout.ms", "5000")
.create() .create()?;
.expect("Producer creation error");
while let Ok(msg) = consumer.recv().await { while let Ok(msg) = consumer.recv().await {
match msg.payload_view::<str>() { match msg.payload_view::<str>() {