This is an automated email from the ASF dual-hosted git repository.
piotr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iggy.git
The following commit(s) were added to refs/heads/master by this push:
new 46313df34 fix(rust): cleanup logs, update edge version (#2334)
46313df34 is described below
commit 46313df344338100ea3518adb72847f510ddb5c2
Author: Piotr Gankiewicz <[email protected]>
AuthorDate: Tue Nov 11 09:38:57 2025 +0100
fix(rust): cleanup logs, update edge version (#2334)
---
Cargo.lock | 18 +++++++++---------
Cargo.toml | 6 +++---
DEPENDENCIES.md | 18 +++++++++---------
core/ai/mcp/Cargo.toml | 2 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/binary_protocol/Cargo.toml | 2 +-
core/cli/Cargo.toml | 2 +-
core/common/Cargo.toml | 2 +-
core/common/src/types/message/user_headers.rs | 6 +++---
core/connectors/runtime/Cargo.toml | 2 +-
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/consumer.rs | 4 ++--
core/server/Cargo.toml | 2 +-
foreign/node/package.json | 2 +-
foreign/python/Cargo.toml | 2 +-
16 files changed, 37 insertions(+), 37 deletions(-)
diff --git a/Cargo.lock b/Cargo.lock
index 1f9fe7446..e98e22885 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -4153,7 +4153,7 @@ dependencies = [
[[package]]
name = "iggy"
-version = "0.8.0-edge.1"
+version = "0.8.0-edge.2"
dependencies = [
"async-broadcast",
"async-dropper",
@@ -4185,7 +4185,7 @@ dependencies = [
[[package]]
name = "iggy-bench"
-version = "0.3.0-edge.1"
+version = "0.3.0-edge.2"
dependencies = [
"async-trait",
"bench-report",
@@ -4215,7 +4215,7 @@ dependencies = [
[[package]]
name = "iggy-bench-dashboard-server"
-version = "0.5.0-edge.1"
+version = "0.5.0-edge.2"
dependencies = [
"actix-cors",
"actix-files",
@@ -4242,7 +4242,7 @@ dependencies = [
[[package]]
name = "iggy-cli"
-version = "0.10.0-edge.1"
+version = "0.10.0-edge.2"
dependencies = [
"ahash 0.8.12",
"anyhow",
@@ -4262,7 +4262,7 @@ dependencies = [
[[package]]
name = "iggy-connectors"
-version = "0.2.0-edge.1"
+version = "0.2.0-edge.2"
dependencies = [
"axum",
"axum-server",
@@ -4293,7 +4293,7 @@ dependencies = [
[[package]]
name = "iggy-mcp"
-version = "0.2.0-edge.1"
+version = "0.2.0-edge.2"
dependencies = [
"axum",
"axum-server",
@@ -4315,7 +4315,7 @@ dependencies = [
[[package]]
name = "iggy_binary_protocol"
-version = "0.8.0-edge.1"
+version = "0.8.0-edge.2"
dependencies = [
"anyhow",
"async-broadcast",
@@ -4336,7 +4336,7 @@ dependencies = [
[[package]]
name = "iggy_common"
-version = "0.8.0-edge.1"
+version = "0.8.0-edge.2"
dependencies = [
"aes-gcm",
"ahash 0.8.12",
@@ -7550,7 +7550,7 @@ dependencies = [
[[package]]
name = "server"
-version = "0.6.0-edge.1"
+version = "0.6.0-edge.2"
dependencies = [
"ahash 0.8.12",
"anyhow",
diff --git a/Cargo.toml b/Cargo.toml
index 37b3425a5..6a1ebd98e 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -120,9 +120,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.1" }
-iggy_binary_protocol = { path = "core/binary_protocol", version =
"0.8.0-edge.1" }
-iggy_common = { path = "core/common", version = "0.8.0-edge.1" }
+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_connector_sdk = { path = "core/connectors/sdk", version = "0.1.0" }
integration = { path = "core/integration" }
keyring = { version = "3.6.3", features = ["sync-secret-service", "vendored"] }
diff --git a/DEPENDENCIES.md b/DEPENDENCIES.md
index 8a57727fb..c81903b44 100644
--- a/DEPENDENCIES.md
+++ b/DEPENDENCIES.md
@@ -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.1, "Apache-2.0",
-iggy-bench: 0.3.0-edge.1, "Apache-2.0",
-iggy-bench-dashboard-server: 0.5.0-edge.1, "Apache-2.0",
-iggy-cli: 0.10.0-edge.1, "Apache-2.0",
-iggy-connectors: 0.2.0-edge.1, "Apache-2.0",
-iggy-mcp: 0.2.0-edge.1, "Apache-2.0",
-iggy_binary_protocol: 0.8.0-edge.1, "Apache-2.0",
-iggy_common: 0.8.0-edge.1, "Apache-2.0",
+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_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.1, "Apache-2.0",
+server: 0.6.0-edge.2, "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",
diff --git a/core/ai/mcp/Cargo.toml b/core/ai/mcp/Cargo.toml
index b2d66c575..e1682f4c8 100644
--- a/core/ai/mcp/Cargo.toml
+++ b/core/ai/mcp/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy-mcp"
-version = "0.2.0-edge.1"
+version = "0.2.0-edge.2"
description = "MCP Server for Iggy message streaming platform"
edition = "2024"
license = "Apache-2.0"
diff --git a/core/bench/Cargo.toml b/core/bench/Cargo.toml
index 736881692..020912961 100644
--- a/core/bench/Cargo.toml
+++ b/core/bench/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy-bench"
-version = "0.3.0-edge.1"
+version = "0.3.0-edge.2"
edition = "2024"
license = "Apache-2.0"
repository = "https://github.com/apache/iggy";
diff --git a/core/bench/dashboard/server/Cargo.toml
b/core/bench/dashboard/server/Cargo.toml
index d9fa3d29b..ddab6ab60 100644
--- a/core/bench/dashboard/server/Cargo.toml
+++ b/core/bench/dashboard/server/Cargo.toml
@@ -18,7 +18,7 @@
[package]
name = "iggy-bench-dashboard-server"
license = "Apache-2.0"
-version = "0.5.0-edge.1"
+version = "0.5.0-edge.2"
edition = "2024"
[dependencies]
diff --git a/core/binary_protocol/Cargo.toml b/core/binary_protocol/Cargo.toml
index 6da97e2fe..68b3eab7c 100644
--- a/core/binary_protocol/Cargo.toml
+++ b/core/binary_protocol/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy_binary_protocol"
-version = "0.8.0-edge.1"
+version = "0.8.0-edge.2"
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"
diff --git a/core/cli/Cargo.toml b/core/cli/Cargo.toml
index ca6842ceb..5e4c4993e 100644
--- a/core/cli/Cargo.toml
+++ b/core/cli/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy-cli"
-version = "0.10.0-edge.1"
+version = "0.10.0-edge.2"
edition = "2024"
authors = ["[email protected]"]
repository = "https://github.com/apache/iggy";
diff --git a/core/common/Cargo.toml b/core/common/Cargo.toml
index b37484ff4..c848822b3 100644
--- a/core/common/Cargo.toml
+++ b/core/common/Cargo.toml
@@ -16,7 +16,7 @@
# under the License.
[package]
name = "iggy_common"
-version = "0.8.0-edge.1"
+version = "0.8.0-edge.2"
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"
diff --git a/core/common/src/types/message/user_headers.rs
b/core/common/src/types/message/user_headers.rs
index 93bcf980d..facd90441 100644
--- a/core/common/src/types/message/user_headers.rs
+++ b/core/common/src/types/message/user_headers.rs
@@ -638,13 +638,13 @@ impl BytesSerializable for HashMap<HeaderKey,
HeaderValue> {
.map_err(|_| IggyError::InvalidNumberEncoding)?,
) as usize;
if key_length == 0 || key_length > 255 {
- tracing::error!("A Invalid header key length: {}", key_length);
+ tracing::error!("Invalid header key length: {key_length}");
return Err(IggyError::InvalidHeaderKey);
}
position += 4;
let key = String::from_utf8(bytes[position..position +
key_length].to_vec());
if key.is_err() {
- tracing::error!("B Invalid header key: {}", key.unwrap_err());
+ tracing::error!("Invalid header key: {}", key.unwrap_err());
return Err(IggyError::InvalidHeaderKey);
}
let key = key.unwrap();
@@ -657,7 +657,7 @@ impl BytesSerializable for HashMap<HeaderKey, HeaderValue> {
.map_err(|_| IggyError::InvalidNumberEncoding)?,
) as usize;
if value_length == 0 || value_length > 255 {
- println!("C Invalid header value length: {value_length}");
+ tracing::error!("Invalid header value length: {value_length}");
return Err(IggyError::InvalidHeaderValue);
}
position += 4;
diff --git a/core/connectors/runtime/Cargo.toml
b/core/connectors/runtime/Cargo.toml
index 2c03700cc..bbe871634 100644
--- a/core/connectors/runtime/Cargo.toml
+++ b/core/connectors/runtime/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy-connectors"
-version = "0.2.0-edge.1"
+version = "0.2.0-edge.2"
description = "Connectors runtime for Iggy message streaming platform"
edition = "2024"
license = "Apache-2.0"
diff --git a/core/sdk/Cargo.toml b/core/sdk/Cargo.toml
index cd8b7b1bd..60182bd34 100644
--- a/core/sdk/Cargo.toml
+++ b/core/sdk/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "iggy"
-version = "0.8.0-edge.1"
+version = "0.8.0-edge.2"
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"
diff --git a/core/sdk/src/clients/consumer.rs b/core/sdk/src/clients/consumer.rs
index 4945eb801..0760d3f8a 100644
--- a/core/sdk/src/clients/consumer.rs
+++ b/core/sdk/src/clients/consumer.rs
@@ -502,8 +502,8 @@ impl IggyConsumer {
warn!("Auto join consumer group is disabled");
return Ok(());
}
- tracing::error!(
- "creating consumer group for stream_id: {:?}, topic_id: {:?},
consumer: {:?}",
+ tracing::debug!(
+ "Initializing consumer group for stream ID: {}, topic ID: {},
consumer ID: {}",
self.stream_id,
self.topic_id,
self.consumer
diff --git a/core/server/Cargo.toml b/core/server/Cargo.toml
index 09852f49f..e2109d7f3 100644
--- a/core/server/Cargo.toml
+++ b/core/server/Cargo.toml
@@ -17,7 +17,7 @@
[package]
name = "server"
-version = "0.6.0-edge.1"
+version = "0.6.0-edge.2"
edition = "2024"
build = "src/build.rs"
license = "Apache-2.0"
diff --git a/foreign/node/package.json b/foreign/node/package.json
index f3d4645b6..c3156539e 100644
--- a/foreign/node/package.json
+++ b/foreign/node/package.json
@@ -1,7 +1,7 @@
{
"name": "apache-iggy",
"type": "module",
- "version": "0.6.0-edge.1",
+ "version": "0.6.0-edge.2",
"description": "Official Apache Iggy NodeJS SDK",
"keywords": [
"iggy",
diff --git a/foreign/python/Cargo.toml b/foreign/python/Cargo.toml
index 01b8bfe2a..3f983c0e1 100644
--- a/foreign/python/Cargo.toml
+++ b/foreign/python/Cargo.toml
@@ -27,7 +27,7 @@ repository = "https://github.com/apache/iggy";
[dependencies]
bytes = "1.10.1"
-iggy = { path = "../../core/sdk", version = "0.8.0-edge.1" }
+iggy = { path = "../../core/sdk", version = "0.8.0-edge.2" }
pyo3 = "0.26.0"
pyo3-async-runtimes = { version = "0.26.0", features = [
"attributes",
