This is an automated email from the ASF dual-hosted git repository. numinnex pushed a commit to branch replicated_crash_contract in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 50adec6dcbfdcbbff96444452108c7229c3d48b6 Merge: 0fd97a3ee 7b053f4cb Author: Grzegorz Koszyk <[email protected]> AuthorDate: Wed Nov 4 11:23:45 2026 +0100 merge master Co-Authored-By: Claude Opus 5.5 <[email protected]> .github/workflows/_build_python_wheels.yml | 10 +- .github/workflows/_common.yml | 4 +- .github/workflows/_publish_rust_crates.yml | 8 +- .github/workflows/_test_examples.yml | 4 +- .github/workflows/coverage-baseline.yml | 6 +- .github/workflows/post-merge.yml | 2 +- .github/workflows/publish.yml | 2 +- Cargo.lock | 75 ++-- Cargo.toml | 11 +- bdd/python/uv.lock | 2 +- core/ai/mcp/Cargo.toml | 2 +- core/bench/Cargo.toml | 2 +- core/bench/dashboard/frontend/Cargo.toml | 2 +- core/bench/dashboard/server/Cargo.toml | 2 +- core/bench/report/Cargo.toml | 2 +- core/binary_protocol/Cargo.toml | 2 +- core/certs/iggy_cert.pem | 20 +- core/cli/Cargo.toml | 2 +- core/common/Cargo.toml | 2 +- core/common/src/http/messages/send_messages.rs | 202 ++++++++++- core/common/src/types/message/iggy_message.rs | 53 +++ core/common/src/types/message/mod.rs | 5 +- core/common/src/types/message/user_headers.rs | 391 ++++++++++++++++++++- core/common/src/wire_conversions.rs | 18 +- core/connectors/runtime/Cargo.toml | 2 +- .../example_config/connectors/iceberg_sink.toml | 5 +- core/connectors/sdk/Cargo.toml | 3 +- core/connectors/sdk/src/log.rs | 27 +- core/connectors/sdk/src/sink.rs | 8 +- core/connectors/sdk/src/source.rs | 8 +- core/connectors/sdk/tests/plugin_logging.rs | 100 ++++++ core/connectors/sinks/bigquery_sink/Cargo.toml | 2 +- core/connectors/sinks/clickhouse_sink/Cargo.toml | 2 +- core/connectors/sinks/delta_sink/Cargo.toml | 6 +- core/connectors/sinks/delta_sink/src/coercions.rs | 27 +- core/connectors/sinks/delta_sink/src/lib.rs | 4 +- core/connectors/sinks/delta_sink/src/sink.rs | 75 +++- core/connectors/sinks/doris_sink/Cargo.toml | 2 +- .../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +- core/connectors/sinks/http_sink/Cargo.toml | 2 +- core/connectors/sinks/iceberg_sink/Cargo.toml | 3 +- core/connectors/sinks/iceberg_sink/README.md | 29 +- core/connectors/sinks/iceberg_sink/config.toml | 2 +- core/connectors/sinks/iceberg_sink/src/lib.rs | 9 +- core/connectors/sinks/iceberg_sink/src/props.rs | 31 +- .../iceberg_sink/src/router/dynamic_router.rs | 22 +- .../sinks/iceberg_sink/src/router/mod.rs | 7 +- core/connectors/sinks/iceberg_sink/src/sink.rs | 7 +- core/connectors/sinks/influxdb_sink/Cargo.toml | 2 +- core/connectors/sinks/meilisearch_sink/Cargo.toml | 2 +- core/connectors/sinks/mongodb_sink/Cargo.toml | 2 +- core/connectors/sinks/postgres_sink/Cargo.toml | 2 +- core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +- core/connectors/sinks/rabbitmq_sink/Cargo.toml | 2 +- core/connectors/sinks/redshift_sink/Cargo.toml | 2 +- core/connectors/sinks/s3_sink/Cargo.toml | 2 +- core/connectors/sinks/stdout_sink/Cargo.toml | 2 +- core/connectors/sinks/surrealdb_sink/Cargo.toml | 2 +- .../sources/elasticsearch_source/Cargo.toml | 2 +- core/connectors/sources/http_source/Cargo.toml | 2 +- core/connectors/sources/influxdb_source/Cargo.toml | 2 +- core/connectors/sources/mqtt_source/Cargo.toml | 2 +- core/connectors/sources/postgres_source/Cargo.toml | 5 +- core/connectors/sources/postgres_source/src/lib.rs | 6 +- core/connectors/sources/random_source/Cargo.toml | 2 +- .../tests/server/consumer_offset_recovery.rs | 142 ++++++++ core/integration/tests/server/http_vsr.rs | 83 +++++ core/integration/tests/server/mod.rs | 1 + core/partitions/src/iggy_partition.rs | 18 + core/partitions/src/lib.rs | 9 +- core/partitions/src/partition_storage.rs | 180 ++++++---- core/sdk/Cargo.toml | 2 +- core/sdk/src/links/mux.rs | 14 +- core/sdk/src/prelude.rs | 34 +- core/server/Cargo.toml | 2 +- core/server/server.http | 17 +- core/server/src/http/extractor.rs | 40 ++- core/server/src/http/handlers.rs | 12 +- core/server/src/partition_helpers.rs | 19 +- examples/python/uv.lock | 2 +- foreign/cpp/Cargo.toml | 2 +- foreign/cpp/MODULE.bazel | 2 +- foreign/cpp/src/type_conversion.rs | 18 +- foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +- foreign/go/contracts/version.go | 2 +- foreign/java/gradle.properties | 2 +- foreign/java/gradle/libs.versions.toml | 2 +- foreign/node/package-lock.json | 4 +- foreign/node/package.json | 2 +- foreign/php/Cargo.toml | 2 +- foreign/python/Cargo.toml | 4 +- foreign/python/pyproject.toml | 2 +- foreign/python/src/user_headers.rs | 7 +- foreign/python/tests/test_message_operations.py | 4 +- foreign/python/uv.lock | 2 +- foreign/swift/Sources/Iggy/Iggy.swift | 2 +- foreign/swift/Tests/IggyTests/Fixtures/golden.json | 8 +- gateways/kafka/Cargo.toml | 2 +- scripts/prepare-release.sh | 15 +- web/package-lock.json | 4 +- web/package.json | 2 +- 101 files changed, 1540 insertions(+), 380 deletions(-)
