Skip to content

Commit 9ab8172

Browse files
committed
small performance improvement in HashRoutingMurmurStrategy
1 parent 19fa5bf commit 9ab8172

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

src/superstream.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -68,9 +68,10 @@ impl HashRoutingMurmurStrategy {
6868
let key = (self.routing_extractor)(message);
6969
let hash_result = murmur3_32(&mut Cursor::new(key), 104729);
7070

71-
let number_of_partitions = metadata.partitions().await.len();
72-
let route = hash_result.unwrap() % number_of_partitions as u32;
7371
let partitions = metadata.partitions().await;
72+
let number_of_partitions = partitions.len();
73+
let route = hash_result.unwrap() % number_of_partitions as u32;
74+
7475
let stream = partitions.into_iter().nth(route as usize).unwrap();
7576
streams.push(stream);
7677

0 commit comments

Comments
 (0)