clippy fixes

Author: rerpha

src/consume.rs

@@ -55,21 +55,21 @@ pub fn consume(
             "offset ({offset:?}) must be between high ({high_watermark}) and low({low_watermark}) watermarks"
         );
         start = Some(Offset::Offset(offset.unwrap()));
-    } else if last.is_some() {
+    } else if let Some(last_num_messages) = last {
         assert!(
-            last.unwrap() <= num_messages_on_topic,
-            "Cannot consume {last:?} messages from a topic which only has {num_messages_on_topic} messages"
+            last_num_messages <= num_messages_on_topic,
+            "Cannot consume {last_num_messages:?} messages from a topic which only has {num_messages_on_topic} messages"
         );
-        start = Some(Offset::Offset(high_watermark - last.unwrap()));
+        start = Some(Offset::Offset(high_watermark - last_num_messages));
     } else {
         start = None;
     }
 
-    if start.is_some() {
-        info!("Starting at {start:?}");
+    if let Some(_start) = start {
+        info!("Starting at {_start:?}");
         let mut tpl = TopicPartitionList::new();
-        tpl.add_partition_offset(&topic.topic, partition.unwrap_or(0), start.unwrap())
-            .unwrap_or_else(|_| panic!("Failed to set partition offset to {:?}", start.unwrap()));
+        tpl.add_partition_offset(&topic.topic, partition.unwrap_or(0), _start)
+            .unwrap_or_else(|_| panic!("Failed to set partition offset to {:?}", _start));
         consumer.assign(&tpl).expect("Failed to assign to topic");
     }
 
@@ -89,9 +89,10 @@ pub fn consume(
                     Some(p) => {
                         if let Some(f) = filter {
                             if let Some(schema_id) = get_schema_id(p)
-                                && schema_id != f.to_bytes() {
-                                    continue;
-                                }
+                                && schema_id != f.to_bytes()
+                            {
+                                continue;
+                            }
                             debug!("Message has no schema id, ignoring filter")
                         }