diff --git a/src/connection.rs b/src/connection.rs index 2e82439..9a90ddf 100644 --- a/src/connection.rs +++ b/src/connection.rs @@ -1474,6 +1474,7 @@ pub(crate) mod messages { publish_time: Utc::now().timestamp_millis() as u64, replicated_from: None, partition_key: message.partition_key, + ordering_key: message.ordering_key, replicate_to: message.replicate_to, compression: message.compression, uncompressed_size: message.uncompressed_size,