From 27ddab1547a3093c81b873cf9cbd2fb67ae75d57 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Stefan=20D=C3=B6rig?= <sdoerig@bluewin.ch>
Date: Tue, 27 Jul 2021 11:26:56 +0200
Subject: [PATCH] Removed warnings

---
 clients/cloud/rust/src/consumer.rs | 2 +-
 clients/cloud/rust/src/producer.rs | 4 ++--
 clients/cloud/rust/src/utils.rs    | 6 +++---
 3 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/clients/cloud/rust/src/consumer.rs b/clients/cloud/rust/src/consumer.rs
index 71dba4ff4..ce7d2877c 100644
--- a/clients/cloud/rust/src/consumer.rs
+++ b/clients/cloud/rust/src/consumer.rs
@@ -44,7 +44,7 @@ fn main() -> Result<(), Box<dyn std::error::Error>> {
     let (topic, mut config) = utils::get_config()?;
     let consumer: StreamConsumer = config.set("group.id", "rust_example_group_1").create()?;
 
-    consumer.subscribe(&vec![topic.as_ref()])?;
+    consumer.subscribe(&[&topic])?;
 
     let processor = consumer
         .start()
diff --git a/clients/cloud/rust/src/producer.rs b/clients/cloud/rust/src/producer.rs
index 77b47e9d1..8a54c9b3d 100644
--- a/clients/cloud/rust/src/producer.rs
+++ b/clients/cloud/rust/src/producer.rs
@@ -26,12 +26,12 @@ fn log_produce_result(
     result: Result<(i32, i64), (KafkaError, OwnedMessage)>,
 ) -> Result<(), ()> {
     result
-        .and_then(|(p, o)| {
+        .map(|(p, o)| {
             println!(
                 "Successfully produced record to topic {} partition [{}] @ offset {}",
                 topic, p, o
             );
-            Ok(())
+            
         })
         .map_err(|(err, _)| eprintln!("kafka error: {}", err))
 }
diff --git a/clients/cloud/rust/src/utils.rs b/clients/cloud/rust/src/utils.rs
index cc7d496c7..4e3d6e9f4 100644
--- a/clients/cloud/rust/src/utils.rs
+++ b/clients/cloud/rust/src/utils.rs
@@ -20,7 +20,7 @@ use std::fs::File;
 use std::io::BufRead;
 use std::io::BufReader;
 
-pub fn get_config() -> Result<(String, ClientConfig), Box<std::error::Error>> {
+pub fn get_config() -> Result<(String, ClientConfig), Box<dyn std::error::Error>> {
     let matches = App::new("rust client example")
         .version(option_env!("CARGO_PKG_VERSION").unwrap_or(""))
         .arg(
@@ -44,10 +44,10 @@ pub fn get_config() -> Result<(String, ClientConfig), Box<std::error::Error>> {
     let file = File::open(matches.value_of("config").ok_or("error parsing config")?)?;
     for line in BufReader::new(&file).lines() {
         let cur_line: String = line?.trim().to_string();
-        if cur_line.starts_with('#') || cur_line.len() < 1 {
+        if cur_line.starts_with('#') || cur_line.is_empty() {
             continue;
         }
-        let key_value: Vec<&str> = cur_line.split("=").collect();
+        let key_value: Vec<&str> = cur_line.split('=').collect();
         kafka_config.set(
             key_value.get(0).ok_or("malformed key")?,
             key_value.get(1).ok_or("malformed value")?,