This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch consumer_offset_clamp
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 8374ca7ad fix(server): clamp recovered consumer offsets after the WAL
replay
add 89dc4a269 feat(swift): publish the SDK to SwiftPM from the repository
root (#4714)
add 35915be1e fix(connectors): address Iceberg sink issues batch (#4736)
add ec6b651b2 fix(common): reject malformed user headers during
deserialization (#4670)
add bc7fa8634 Merge branch 'master' into consumer_offset_clamp
No new revisions were added by this update.
Summary of changes:
.github/actions/swift/post-merge/action.yml | 94 +++++
.github/actions/swift/pre-merge/action.yml | 28 ++
.github/actions/utils/setup-swift/action.yml | 36 +-
.github/config/components.yml | 2 +
.github/config/publish.yml | 7 +
.github/workflows/_test_examples.yml | 8 +
.github/workflows/post-merge.yml | 5 +-
.github/workflows/publish.yml | 89 ++++-
.gitignore | 4 +
.../agents/openai.yaml => .spi.yml | 7 +-
AGENTS.md | 4 +-
Cargo.lock | 6 +-
Cargo.toml | 3 +-
foreign/swift/Package.swift => Package.swift | 28 +-
README.md | 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 +-
.../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/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/integration/tests/server/http_vsr.rs | 83 +++++
core/sdk/src/prelude.rs | 34 +-
core/server/config.toml | 1 +
core/server/server.http | 17 +-
core/server/src/http/extractor.rs | 40 ++-
core/server/src/http/handlers.rs | 12 +-
foreign/cpp/src/type_conversion.rs | 18 +-
foreign/python/src/user_headers.rs | 7 +-
foreign/python/tests/test_message_operations.py | 4 +-
foreign/{csharp => swift}/LICENSE | 0
NOTICE => foreign/swift/NOTICE | 0
foreign/swift/Package.swift | 2 +-
foreign/swift/README.md | 35 +-
foreign/swift/Sources/Iggy/Iggy.swift | 5 +-
foreign/swift/Tests/IggyTests/Fixtures/golden.json | 8 +-
scripts/bump-version.sh | 41 ++-
scripts/prepare-release.sh | 1 +
51 files changed, 1353 insertions(+), 208 deletions(-)
create mode 100644 .github/actions/swift/post-merge/action.yml
copy .claude/skills/connector-review/agents/openai.yaml => .spi.yml (85%)
copy foreign/swift/Package.swift => Package.swift (75%)
create mode 100644 core/connectors/sdk/tests/plugin_logging.rs
copy foreign/{csharp => swift}/LICENSE (100%)
copy NOTICE => foreign/swift/NOTICE (100%)
