Update rdkafka version and fix lint warning

Signed-off-by: Falk Woldmann Lu <52786457+FalkWoldmann@users.noreply.github.com>

Author: FalkWoldmann

Cargo.toml

@@ -48,7 +48,7 @@ uuid = { version = "1", features = ["v4"] }
 actix-web = { version = "4", optional = true }
 actix-http = { version = "3", optional = true }
 reqwest-lib = { version = "^0.12", default-features = false, features = ["rustls-tls"], optional = true, package = "reqwest" }
-rdkafka-lib = { version = "^0.38", features = ["cmake-build"], optional = true, package = "rdkafka" }
+rdkafka-lib = { version = "0.39", features = ["cmake-build"], optional = true, package = "rdkafka" }
 warp-lib = { version = "^0.3", optional = true, package = "warp" }
 async-trait = { version = "^0.1", optional = true }
 bytes = { version = "^1.0", optional = true }

src/binding/rdkafka/kafka_consumer_record.rs

@@ -94,8 +94,8 @@ impl BinaryDeserializer for ConsumerRecordDeserializer {
             }
         }
 
-        if self.payload.is_some() {
-            visitor.end_with_data(self.payload.unwrap())
+        if let Some(payload) = self.payload {
+            visitor.end_with_data(payload)
         } else {
             visitor.end()
         }