This is an automated email from the ASF dual-hosted git repository.
spetz pushed a change to branch kafka-fetch-stall
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 46867d8ef fix(gateways): keep Kafka Fetch answering when one partition
stalls
add 763c8edd9 fix(sdk): resume stopped partitions and keep readiness waits
current (#4693)
add 430d976cc feat(java): let clients close without Netty's 2 s quiet
period (#4704)
add eef3f6888 test(gateways): add failover tests for gateways beside a
3-node cluster (#4702)
add 253395d67 Merge branch 'master' into kafka-fetch-stall
No new revisions were added by this update.
Summary of changes:
.claude/skills/connector-runtime/SKILL.md | 2 +
.config/nextest.toml | 25 +
.github/actions/rust/pre-merge/action.yml | 12 +-
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/java/README.md | 21 +
.../kotlin/iggy.java-common-conventions.gradle.kts | 3 +
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 13 +-
.../async/tcp/AsyncIggyTcpClientBuilder.java | 43 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 17 +-
.../iggy/client/async/tcp/EventLoopShutdown.java | 109 +
.../client/blocking/tcp/IggyTcpClientBuilder.java | 24 +
.../tcp/AsyncIggyTcpClientEventLoopGroupTest.java | 38 +-
.../tcp/AsyncIggyTcpClientFailoverSignInTest.java | 3 +-
.../tcp/AsyncIggyTcpClientLoginRoutingTest.java | 3 +-
.../tcp/AsyncIggyTcpClientSessionRulesTest.java | 3 +-
.../client/async/tcp/EventLoopShutdownTest.java | 127 ++
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 +-
gateways/kafka/README.md | 10 +-
gateways/kafka/docs/AUTHENTICATION.md | 2 +-
gateways/kafka/docs/CONSUMER_GROUPS.md | 11 +-
gateways/kafka/docs/TEST_SUITE.md | 25 +-
gateways/kafka/tests/cluster_failover_tests.rs | 2351 ++++++++++++++++++++
gateways/kafka/tests/common/deployment.rs | 467 ++++
gateways/kafka/tests/common/docker_clients.rs | 296 +++
gateways/kafka/tests/common/iggy_server.rs | 60 +
81 files changed, 5121 insertions(+), 180 deletions(-)
create mode 100644 core/sdk/tests/send_future_depth.rs
create mode 100644 core/simulator/src/readiness_mirror_tests.rs
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/EventLoopShutdown.java
create mode 100644
foreign/java/java-sdk/src/test/java/org/apache/iggy/client/async/tcp/EventLoopShutdownTest.java
create mode 100644 gateways/kafka/tests/cluster_failover_tests.rs
create mode 100644 gateways/kafka/tests/common/deployment.rs
create mode 100644 gateways/kafka/tests/common/docker_clients.rs
