feat(server): replace crc32fast with xxHash3, use uuidV4 for random message ID (#2341)

BREAKING

---------

Co-authored-by: Łukasz Zborek <[email protected]>

Author: spetz

Cargo.lock

@@ -100,7 +100,6 @@ compio-ws = { git = "https://github.com/krishvishal/compio-ws", rev = "b30c9e4cd
     "rustls",
 ] }
 console-subscriber = "0.5.0"
-crc32fast = "1.5.0"
 crossbeam = "0.8.4"
 cyper = { version = "0.6.2", features = ["rustls"], default-features = false }
 cyper-axum = { version = "0.6.0" }
@@ -120,9 +119,9 @@ futures = "0.3.31"
 futures-util = "0.3.31"
 human-repr = "1.1.0"
 humantime = "2.3.0"
-iggy = { path = "core/sdk", version = "0.8.0-edge.2" }
-iggy_binary_protocol = { path = "core/binary_protocol", version = "0.8.0-edge.2" }
-iggy_common = { path = "core/common", version = "0.8.0-edge.2" }
+iggy = { path = "core/sdk", version = "0.8.0-edge.3" }
+iggy_binary_protocol = { path = "core/binary_protocol", version = "0.8.0-edge.3" }
+iggy_common = { path = "core/common", version = "0.8.0-edge.3" }
 iggy_connector_sdk = { path = "core/connectors/sdk", version = "0.1.0" }
 integration = { path = "core/integration" }
 keyring = { version = "3.6.3", features = ["sync-secret-service", "vendored"] }

Cargo.toml

@@ -368,14 +368,14 @@ icu_provider: 2.1.1, "Unicode-3.0",
 ident_case: 1.0.1, "Apache-2.0 OR MIT",
 idna: 1.1.0, "Apache-2.0 OR MIT",
 idna_adapter: 1.2.1, "Apache-2.0 OR MIT",
-iggy: 0.8.0-edge.2, "Apache-2.0",
-iggy-bench: 0.3.0-edge.2, "Apache-2.0",
-iggy-bench-dashboard-server: 0.5.0-edge.2, "Apache-2.0",
-iggy-cli: 0.10.0-edge.2, "Apache-2.0",
-iggy-connectors: 0.2.0-edge.2, "Apache-2.0",
-iggy-mcp: 0.2.0-edge.2, "Apache-2.0",
-iggy_binary_protocol: 0.8.0-edge.2, "Apache-2.0",
-iggy_common: 0.8.0-edge.2, "Apache-2.0",
+iggy: 0.8.0-edge.3, "Apache-2.0",
+iggy-bench: 0.3.0-edge.3, "Apache-2.0",
+iggy-bench-dashboard-server: 0.5.0-edge.3, "Apache-2.0",
+iggy-cli: 0.10.0-edge.3, "Apache-2.0",
+iggy-connectors: 0.2.0-edge.3, "Apache-2.0",
+iggy-mcp: 0.2.0-edge.3, "Apache-2.0",
+iggy_binary_protocol: 0.8.0-edge.3, "Apache-2.0",
+iggy_common: 0.8.0-edge.3, "Apache-2.0",
 iggy_connector_postgres_sink: 0.1.0, "Apache-2.0",
 iggy_connector_postgres_source: 0.1.0, "Apache-2.0",
 iggy_connector_quickwit_sink: 0.1.0, "Apache-2.0",
@@ -670,7 +670,7 @@ serde_with_macros: 3.15.1, "Apache-2.0 OR MIT",
 serde_yaml_ng: 0.10.0, "MIT",
 serial_test: 3.2.0, "MIT",
 serial_test_derive: 3.2.0, "MIT",
-server: 0.6.0-edge.2, "Apache-2.0",
+server: 0.6.0-edge.3, "Apache-2.0",
 sha1: 0.10.6, "Apache-2.0 OR MIT",
 sha2: 0.10.9, "Apache-2.0 OR MIT",
 sharded-slab: 0.1.7, "MIT",

DEPENDENCIES.md

@@ -17,7 +17,7 @@
 
 [package]
 name = "iggy-mcp"
-version = "0.2.0-edge.2"
+version = "0.2.0-edge.3"
 description = "MCP Server for Iggy message streaming platform"
 edition = "2024"
 license = "Apache-2.0"

core/ai/mcp/Cargo.toml

@@ -17,7 +17,7 @@
 
 [package]
 name = "iggy-bench"
-version = "0.3.0-edge.2"
+version = "0.3.0-edge.3"
 edition = "2024"
 license = "Apache-2.0"
 repository = "https://github.com/apache/iggy"

core/bench/Cargo.toml

@@ -18,7 +18,7 @@
 [package]
 name = "iggy-bench-dashboard-server"
 license = "Apache-2.0"
-version = "0.5.0-edge.2"
+version = "0.5.0-edge.3"
 edition = "2024"
 
 [dependencies]

core/bench/dashboard/server/Cargo.toml

@@ -17,7 +17,7 @@
 
 [package]
 name = "iggy_binary_protocol"
-version = "0.8.0-edge.2"
+version = "0.8.0-edge.3"
 description = "Iggy is the persistent message streaming platform written in Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing millions of messages per second."
 edition = "2024"
 license = "Apache-2.0"

core/binary_protocol/Cargo.toml

@@ -17,7 +17,7 @@
 
 [package]
 name = "iggy-cli"
-version = "0.10.0-edge.2"
+version = "0.10.0-edge.3"
 edition = "2024"
 authors = ["[email protected]"]
 repository = "https://github.com/apache/iggy"

core/cli/Cargo.toml

@@ -16,7 +16,7 @@
 # under the License.
 [package]
 name = "iggy_common"
-version = "0.8.0-edge.2"
+version = "0.8.0-edge.3"
 description = "Iggy is the persistent message streaming platform written in Rust, supporting QUIC, TCP and HTTP transport protocols, capable of processing millions of messages per second."
 edition = "2024"
 license = "Apache-2.0"
@@ -42,7 +42,6 @@ bytes = { workspace = true }
 chrono = { workspace = true }
 clap = { workspace = true }
 comfy-table = { workspace = true }
-crc32fast = { workspace = true }
 derive_more = { workspace = true }
 fast-async-mutex = { version = "0.6.7", optional = true }
 figment = { workspace = true }
@@ -58,3 +57,4 @@ tokio = { workspace = true }
 toml = { workspace = true }
 tracing = { workspace = true }
 tungstenite = { workspace = true }
+twox-hash = { workspace = true }

core/common/Cargo.toml

@@ -64,7 +64,7 @@ pub enum IggyError {
     #[error("State file corrupted")]
     StateFileCorrupted = 15,
     #[error("Invalid state entry checksum: {0}, expected: {1}, for index: {2}")]
-    InvalidStateEntryChecksum(u32, u32, u64) = 16,
+    InvalidStateEntryChecksum(u64, u64, u64) = 16,
     #[error("Cannot open database, Path: {0}")]
     CannotOpenDatabase(String) = 19,
     #[error("Resource with key: {0} was not found.")]