chore: updates from review comments

kindredgroup · Nov 11, 2024 · 67140e1 · 67140e1
1 parent 88ca2cc
commit 67140e1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/packages/talos_messenger_actions/src/messenger_with_kafka.rs b/packages/talos_messenger_actions/src/messenger_with_kafka.rs
@@ -94,8 +94,8 @@ pub struct Configuration {
     /// Channel buffer size for the internal channels between threads
     pub channel_buffers: Option<ChannelBuffers>,
     /// Commit size to decide how often the certifier topic can be committed by the consumer.
-    /// The more ofter the commit is done has inverse impact on the latency.
-    /// Defaults to 1_000.
+    /// The more often the commit is done has inverse impact on the latency.
+    /// Defaults to 5_000.
     pub commit_size: Option<u32>,
 }
 

diff --git a/packages/talos_messenger_core/src/services/inbound_service.rs b/packages/talos_messenger_core/src/services/inbound_service.rs
@@ -209,7 +209,7 @@ where
 
                         },
                         MessengerChannelFeedback::Success(version, key) => {
-                            info!("Successfully processed version={version} with action_key={key}");
+                            debug!("Successfully processed version={version} with action_key={key}");
                             self.handle_action_success(version, &key);
                         },
                     }
@@ -268,7 +268,7 @@ where
 
                         },
                         Ok(None) => {
-                            info!("No message to process..");
+                            debug!("No message to process..");
                         },
                         Err(error) => {
                             // Catch the error propogated, and if it has a version, mark the item as completed.