This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch iceberg_catalog_retry
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 0381e1f16 fix(connectors): retry failed Iceberg catalog commits
add 35915be1e fix(connectors): address Iceberg sink issues batch (#4736)
add ec6b651b2 fix(common): reject malformed user headers during
deserialization (#4670)
add 8f2c9ffd6 fix(server): clamp recovered consumer offsets after the WAL
replay (#4737)
add 7d0ab2a17 fix: preserve JSON numbers and synchronize mux cancellation
tests (#4733)
add 17b8c4b11 chore(repo): prepare versions for 0.10.0 release (#4742)
add 91e020636 fix(repo): renew the localhost TLS certificate expiring
2026-11-17 (#4745)
add 55ae03c63 chore(deps): Bump the github-actions group across 1
directory with 6 updates (#4744)
add 7b053f4cb chore(deps): Bump ch.qos.logback:logback-classic from 1.6.5
to 1.6.6 in /foreign/java in the java group across 1 directory (#4743)
add bf6459690 merge master
new 5a1114386 merge master
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.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 +-
README.md | 2 +-
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 +-
.../sinks/iceberg_sink/src/router/commit.rs | 3 +
.../iceberg_sink/src/router/dynamic_router.rs | 22 +-
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/config.toml | 1 +
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 +-
103 files changed, 1539 insertions(+), 380 deletions(-)
create mode 100644 core/connectors/sdk/tests/plugin_logging.rs
create mode 100644 core/integration/tests/server/consumer_offset_recovery.rs
