We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent a9e133f commit 7de83eeCopy full SHA for 7de83ee
console-subscriber/src/aggregator/mod.rs
@@ -294,8 +294,8 @@ impl Aggregator {
294
metadata: (*self.all_metadata).clone(),
295
}),
296
};
297
- let el = update.encoded_len();
298
- if el < MAX_MESSAGE_SIZE {
+ let message_size = update.encoded_len();
+ if message_size < MAX_MESSAGE_SIZE {
299
// normal case
300
break Some(update);
301
}
@@ -305,7 +305,7 @@ impl Aggregator {
305
self.cleanup_closed();
306
tracing::debug!(
307
retention = ?self.retention,
308
- message_size = el,
+ message_size,
309
max_message_size = MAX_MESSAGE_SIZE,
310
"Message too big, reduced retention",
311
);
0 commit comments