fix: ordering key assignment (#290)

Co-authored-by: Qian Wu <[email protected]>
streamnative · Aug 10, 2023 · 7054b8a · 7054b8a
1 parent cfba9e5
commit 7054b8a
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/producer.rs b/src/producer.rs
@@ -1033,8 +1033,8 @@ impl<'a, T, Exe: Executor> MessageBuilder<'a, T, Exe> {
 
     /// sets the message's ordering key for key_shared subscription
     #[cfg_attr(feature = "telemetry", tracing::instrument(skip_all))]
-    pub fn with_ordering_key<S: Into<String>>(mut self, partition_key: S) -> Self {
-        self.partition_key = Some(partition_key.into());
+    pub fn with_ordering_key<S: Into<Vec<u8>>>(mut self, ordering_key: S) -> Self {
+        self.ordering_key = Some(ordering_key.into());
         self
     }