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 4fae9a59a chore(repo): bump Rust version to 1.92.0 (#2480)
4fae9a59a is described below
commit 4fae9a59aa86033366be5ab5c0ca040358dd11e0
Author: Hubert Gruszecki <[email protected]>
AuthorDate: Fri Dec 12 16:07:30 2025 +0100
chore(repo): bump Rust version to 1.92.0 (#2480)
---
.github/actions/utils/docker-buildx/action.yml | 4 +-
Dockerfile | 2 +-
bdd/python/Dockerfile | 2 +-
bdd/rust/Dockerfile | 2 +-
core/ai/mcp/Dockerfile | 2 +-
core/bench/dashboard/server/Dockerfile | 2 +-
core/common/src/types/message/user_headers.rs | 13 +++---
core/connectors/runtime/Dockerfile | 2 +-
core/server/Dockerfile | 2 +-
core/server/src/slab/streams.rs | 64 +++++++++++++++-----------
rust-toolchain.toml | 2 +-
11 files changed, 53 insertions(+), 44 deletions(-)
diff --git a/.github/actions/utils/docker-buildx/action.yml
b/.github/actions/utils/docker-buildx/action.yml
index bffbcd4b8..276cb6e0b 100644
--- a/.github/actions/utils/docker-buildx/action.yml
+++ b/.github/actions/utils/docker-buildx/action.yml
@@ -218,8 +218,8 @@ runs:
echo "RUST_VERSION=$ver" >> "$GITHUB_ENV"
echo "Using toolchain: $ver"
else
- echo "RUST_VERSION=1.91" >> "$GITHUB_ENV"
- echo "No rust-toolchain.toml found; labeling as 1.91"
+ echo "RUST_VERSION=1.92" >> "$GITHUB_ENV"
+ echo "No rust-toolchain.toml found; labeling as 1.92"
fi
- name: Compose build args
diff --git a/Dockerfile b/Dockerfile
index f15bd1e93..588cebdb2 100644
--- a/Dockerfile
+++ b/Dockerfile
@@ -15,7 +15,7 @@
# specific language governing permissions and limitations
# under the License.
-ARG RUST_VERSION=1.91
+ARG RUST_VERSION=1.92
FROM rust:${RUST_VERSION}-slim-bookworm AS builder
diff --git a/bdd/python/Dockerfile b/bdd/python/Dockerfile
index 7cdce1c27..73fddc9e9 100644
--- a/bdd/python/Dockerfile
+++ b/bdd/python/Dockerfile
@@ -16,7 +16,7 @@
# under the License.
# syntax=docker/dockerfile:1
-ARG RUST_VERSION=1.91
+ARG RUST_VERSION=1.92
FROM rust:${RUST_VERSION}-slim-trixie
RUN apt-get update && \
diff --git a/bdd/rust/Dockerfile b/bdd/rust/Dockerfile
index 2e8cc8859..0f1032f2f 100644
--- a/bdd/rust/Dockerfile
+++ b/bdd/rust/Dockerfile
@@ -15,7 +15,7 @@
# specific language governing permissions and limitations
# under the License.
-ARG RUST_VERSION=1.91
+ARG RUST_VERSION=1.92
FROM rust:${RUST_VERSION}
WORKDIR /app
diff --git a/core/ai/mcp/Dockerfile b/core/ai/mcp/Dockerfile
index 3dd11a076..f5fa7e977 100644
--- a/core/ai/mcp/Dockerfile
+++ b/core/ai/mcp/Dockerfile
@@ -15,7 +15,7 @@
# specific language governing permissions and limitations
# under the License.
-ARG RUST_VERSION=1.91
+ARG RUST_VERSION=1.92
ARG ALPINE_VERSION=3.22
FROM --platform=$BUILDPLATFORM
lukemathwalker/cargo-chef:latest-rust-${RUST_VERSION}-alpine AS chef
diff --git a/core/bench/dashboard/server/Dockerfile
b/core/bench/dashboard/server/Dockerfile
index dfd2325d4..29e103824 100644
--- a/core/bench/dashboard/server/Dockerfile
+++ b/core/bench/dashboard/server/Dockerfile
@@ -15,7 +15,7 @@
# specific language governing permissions and limitations
# under the License.
-ARG RUST_VERSION=1.91
+ARG RUST_VERSION=1.92
# Build stage
FROM rust:${RUST_VERSION}-slim-trixie AS builder
diff --git a/core/common/src/types/message/user_headers.rs
b/core/common/src/types/message/user_headers.rs
index facd90441..e5cfa37bf 100644
--- a/core/common/src/types/message/user_headers.rs
+++ b/core/common/src/types/message/user_headers.rs
@@ -642,12 +642,13 @@ impl BytesSerializable for HashMap<HeaderKey,
HeaderValue> {
return Err(IggyError::InvalidHeaderKey);
}
position += 4;
- let key = String::from_utf8(bytes[position..position +
key_length].to_vec());
- if key.is_err() {
- tracing::error!("Invalid header key: {}", key.unwrap_err());
- return Err(IggyError::InvalidHeaderKey);
- }
- let key = key.unwrap();
+ let key = match String::from_utf8(bytes[position..position +
key_length].to_vec()) {
+ Ok(k) => k,
+ Err(e) => {
+ tracing::error!("Invalid header key: {e}");
+ return Err(IggyError::InvalidHeaderKey);
+ }
+ };
position += key_length;
let kind = HeaderKind::from_code(bytes[position])?;
position += 1;
diff --git a/core/connectors/runtime/Dockerfile
b/core/connectors/runtime/Dockerfile
index 4d47e04f2..7e78fe1a5 100644
--- a/core/connectors/runtime/Dockerfile
+++ b/core/connectors/runtime/Dockerfile
@@ -15,7 +15,7 @@
# specific language governing permissions and limitations
# under the License.
-ARG RUST_VERSION=1.91
+ARG RUST_VERSION=1.92
ARG ALPINE_VERSION=3.22
FROM --platform=$BUILDPLATFORM
lukemathwalker/cargo-chef:latest-rust-${RUST_VERSION}-alpine AS chef
diff --git a/core/server/Dockerfile b/core/server/Dockerfile
index 00274ab99..52f9100d4 100644
--- a/core/server/Dockerfile
+++ b/core/server/Dockerfile
@@ -15,7 +15,7 @@
# specific language governing permissions and limitations
# under the License.
-ARG RUST_VERSION=1.91
+ARG RUST_VERSION=1.92
ARG ALPINE_VERSION=3.22
# ── from-source path (unchanged)
──────────────────────────────────────────────
diff --git a/core/server/src/slab/streams.rs b/core/server/src/slab/streams.rs
index 222b9f0e4..ad7d5368d 100644
--- a/core/server/src/slab/streams.rs
+++ b/core/server/src/slab/streams.rs
@@ -387,37 +387,45 @@ impl MainOps for Streams {
.map(|cg_offset| cg_offset.stored_offset),
};
- if consumer_offset.is_none() {
- let batches = self
- .get_messages_by_offset(stream_id, topic_id,
partition_id, 0, count)
- .await?;
- Ok(batches)
- } else {
- let consumer_offset = consumer_offset.unwrap();
- let offset = consumer_offset + 1;
- match consumer {
- PollingConsumer::Consumer(consumer_id, _) => {
- tracing::trace!(
- "Getting next messages for consumer id: {} for
partition: {} from offset: {}...",
- consumer_id,
- partition_id,
- offset
- );
+ match consumer_offset {
+ None => {
+ let batches = self
+ .get_messages_by_offset(stream_id, topic_id,
partition_id, 0, count)
+ .await?;
+ Ok(batches)
+ }
+ Some(consumer_offset) => {
+ let offset = consumer_offset + 1;
+ match consumer {
+ PollingConsumer::Consumer(consumer_id, _) => {
+ tracing::trace!(
+ "Getting next messages for consumer id: {}
for partition: {} from offset: {}...",
+ consumer_id,
+ partition_id,
+ offset
+ );
+ }
+ PollingConsumer::ConsumerGroup(consumer_group_id,
member_id) => {
+ tracing::trace!(
+ "Getting next messages for consumer group:
{} member: {} for partition: {} from offset: {}...",
+ consumer_group_id.0,
+ member_id.0,
+ partition_id,
+ offset
+ );
+ }
}
- PollingConsumer::ConsumerGroup(consumer_group_id,
member_id) => {
- tracing::trace!(
- "Getting next messages for consumer group: {}
member: {} for partition: {} from offset: {}...",
- consumer_group_id.0,
- member_id.0,
+ let batches = self
+ .get_messages_by_offset(
+ stream_id,
+ topic_id,
partition_id,
- offset
- );
- }
+ offset,
+ count,
+ )
+ .await?;
+ Ok(batches)
}
- let batches = self
- .get_messages_by_offset(stream_id, topic_id,
partition_id, offset, count)
- .await?;
- Ok(batches)
}
}
}?;
diff --git a/rust-toolchain.toml b/rust-toolchain.toml
index 8c790afb5..cf05182a0 100644
--- a/rust-toolchain.toml
+++ b/rust-toolchain.toml
@@ -16,6 +16,6 @@
# under the License.
[toolchain]
-channel = "1.91.0"
+channel = "1.92.0"
components = ["rustfmt", "clippy"]
profile = "default"
