This is an automated email from the ASF dual-hosted git repository. spetz pushed a commit to branch kafka-gateway-failover-tests in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 3ac1c620b8743f16d6a5d50d7a1b62b8ea296f6b Merge: bbe9dda55 763c8edd9 Author: Piotr Gankiewicz <[email protected]> AuthorDate: Mon Nov 2 09:17:09 2026 +0100 Merge branch 'master' into kafka-gateway-failover-tests .claude/skills/connector-runtime/SKILL.md | 2 + Cargo.lock | 9 +- Cargo.toml | 5 +- bdd/python/uv.lock | 2 +- core/common/Cargo.toml | 3 +- core/common/src/traits/binary_transport.rs | 60 ++++++- core/common/src/types/message/commit_outcome.rs | 3 + core/connectors/runtime/Cargo.toml | 2 +- core/connectors/runtime/src/sink.rs | 77 ++++++++- core/sdk/Cargo.toml | 2 +- core/sdk/src/clients/producer.rs | 15 ++ core/sdk/src/clients/reader.rs | 8 +- core/sdk/src/clients/reader/cluster_tests.rs | 40 +++++ core/sdk/src/clients/reader/worker.rs | 116 ++++++++++--- core/sdk/src/consumer_ext/consumer_message_ext.rs | 3 +- core/sdk/tests/send_future_depth.rs | 78 +++++++++ core/server/Cargo.toml | 2 +- core/shard/src/lib.rs | 61 ++++++- core/shard/src/poll/deferred.rs | 115 +++++++++++-- core/shard/src/poll/deferred_tests.rs | 188 +++++++++++++++++++++ core/simulator/src/lib.rs | 3 + core/simulator/src/readiness_mirror_tests.rs | 166 ++++++++++++++++++ examples/node/package-lock.json | 2 +- examples/python/uv.lock | 2 +- foreign/cpp/Cargo.toml | 2 +- foreign/cpp/MODULE.bazel | 2 +- foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.cs | 20 ++- .../Iggy_SDK/Consumers/IggyConsumerConfig.cs | 3 + .../csharp/Iggy_SDK/Consumers/PartitionReader.cs | 26 ++- foreign/csharp/Iggy_SDK/Consumers/ReadException.cs | 14 ++ foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +- .../ConsumerTests/ConsumerOnReaderTests.cs | 135 ++++++++++++++- .../Iggy_SDK_Tests/ConsumerTests/ReaderCluster.cs | 10 ++ foreign/csharp/README.md | 14 +- foreign/go/client/reader/reader.go | 20 ++- foreign/go/client/reader/reader_test.go | 81 ++++++++- foreign/go/contracts/version.go | 2 +- foreign/node/README.md | 12 +- foreign/node/package-lock.json | 4 +- foreign/node/package.json | 2 +- foreign/node/src/stream/iggy-consumer.ts | 8 +- foreign/node/src/stream/partition-reader.test.ts | 83 +++++++++ foreign/node/src/stream/partition-reader.ts | 25 ++- foreign/php/Cargo.toml | 2 +- foreign/php/iggy-php.stubs.php | 22 ++- foreign/php/src/consumer.rs | 14 +- foreign/php/src/error.rs | 9 + foreign/python/Cargo.toml | 4 +- foreign/python/apache_iggy.pyi | 13 +- foreign/python/pyproject.toml | 2 +- foreign/python/src/client.rs | 37 ++++ foreign/python/src/consumer.rs | 7 +- foreign/python/uv.lock | 2 +- foreign/swift/README.md | 6 +- .../swift/Sources/Iggy/Consumer/IggyConsumer.swift | 24 ++- .../Sources/Iggy/Consumer/PartitionReader.swift | 22 ++- foreign/swift/Sources/Iggy/Iggy.swift | 2 +- foreign/swift/Tests/IggyTests/ConsumerTests.swift | 35 ++++ foreign/swift/Tests/IggyTests/Fixtures/golden.json | 8 +- 59 files changed, 1490 insertions(+), 148 deletions(-)
