Skip to content

Commit

Permalink
fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
ayirr7 committed Sep 11, 2024
1 parent f7f1336 commit 4255f5b
Showing 1 changed file with 4 additions and 7 deletions.
11 changes: 4 additions & 7 deletions rust-arroyo/src/processing/dlq.rs
Original file line number Diff line number Diff line change
Expand Up @@ -425,13 +425,10 @@ impl<TPayload> BufferedMessages<TPayload> {
buffered.push_back(message);

// Number of elements that can be held in buffer deque without reallocating
if metric_prob <= 0.01 {
// Number of partitions in the buffer map
gauge!(
"arroyo.consumer.dlq_buffer.assigned_partitions",
self.buffered_messages.len() as u64,
);
}
gauge!(
"arroyo.consumer.dlq_buffer.capacity",
buffered.capacity() as u64
);
}

/// Return the message at the given offset or None if it is not found in the buffer.
Expand Down

0 comments on commit 4255f5b

Please sign in to comment.