run fmt, clippy

Author: slbotbm

foreign/cpp/src/client.rs

@@ -99,14 +99,15 @@ impl Client {
         expiry_value: u32,
         max_topic_size: String,
     ) -> Result<(), String> {
-        let compression_algorithm =
-            RustCompressionAlgorithm::from_str(compression_algorithm.as_str())
-            .map_err(|error| {
-                format!(
-                    "Could not parse compression algorithm '{}': {error}",
-                    compression_algorithm
-                )
-            })?;
+        let compression_algorithm = RustCompressionAlgorithm::from_str(
+            compression_algorithm.as_str(),
+        )
+        .map_err(|error| {
+            format!(
+                "Could not parse compression algorithm '{}': {error}",
+                compression_algorithm
+            )
+        })?;
         let replication_factor = if replication_factor == 0 {
             None
         } else {
@@ -125,11 +126,11 @@ impl Client {
         };
         let max_topic_size =
             RustMaxTopicSize::from_str(max_topic_size.as_str()).map_err(|error| {
-            format!(
-                "Could not parse max topic size '{}': {error}",
-                max_topic_size
-            )
-        })?;
+                format!(
+                    "Could not parse max topic size '{}': {error}",
+                    max_topic_size
+                )
+            })?;
 
         RUNTIME
             .block_on(self.inner.create_topic(
@@ -170,6 +171,7 @@ impl Client {
         Ok(())
     }
 
+    #[allow(clippy::too_many_arguments)]
     pub(crate) fn poll_messages(
         &self,
         stream_id: &Identifier,

foreign/cpp/src/lib.rs

@@ -85,6 +85,7 @@ mod ffi {
             topic: &Identifier,
             partitioning: u32,
         ) -> Result<()>;
+        #[allow(clippy::too_many_arguments)]
         fn poll_messages(
             self: &Client,
             stream_id: &Identifier,