This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch durable-offset-watermark
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 4f367dafe fix(server): let the chain guard admit the boot re-anchor's
gap
add ffb186dba feat(gateways): iggy gateway for kafka listener (#3519)
add 9c6451d62 fix(consensus): keep a late retry's reply instead of
refusing it (#3945)
add 7b491c09f fix(cluster): prevent repaired prepares from rewinding WAL
parent (#3978)
add 6a9064080 Merge branch 'master' into durable-offset-watermark
No new revisions were added by this update.
Summary of changes:
.github/actions/rust/pre-merge/action.yml | 38 +
.github/config/components.yml | 10 +
.github/workflows/pr-title.yml | 1 +
.gitignore | 1 +
Cargo.lock | 70 ++
Cargo.toml | 2 +
.../configs/src/configs_impl/typed_env_provider.rs | 13 +-
core/consensus/src/client_table.rs | 254 +++++-
core/consensus/src/metadata_helpers.rs | 8 +-
core/consensus/src/plane_helpers.rs | 62 ++
.../tests/cluster/client_table_adversarial.rs | 56 +-
core/journal/src/prepare_journal.rs | 40 +
core/partitions/src/iggy_partition.rs | 121 ++-
core/shard/src/lib.rs | 29 +-
core/simulator/src/lib.rs | 155 ++++
gateways/README.md | 9 +
{core/bench => gateways/kafka}/Cargo.toml | 57 +-
gateways/kafka/README.md | 63 ++
gateways/kafka/docs/MANUAL_TESTING.md | 307 +++++++
gateways/kafka/docs/SCOPE.md | 138 +++
gateways/kafka/docs/TEST_SUITE.md | 66 ++
gateways/kafka/docs/kafka_api_keys_reference.md | 316 +++++++
gateways/kafka/scripts/ci-wire-fixtures.sh | 57 ++
gateways/kafka/src/error.rs | 45 +
.../steps/mod.rs => gateways/kafka/src/lib.rs | 12 +-
gateways/kafka/src/main.rs | 240 +++++
gateways/kafka/src/protocol/api.rs | 637 +++++++++++++
gateways/kafka/src/protocol/bounds_guard.rs | 906 +++++++++++++++++++
gateways/kafka/src/protocol/header.rs | 40 +
.../helpers => gateways/kafka/src/protocol}/mod.rs | 6 +-
gateways/kafka/src/protocol/responses.rs | 318 +++++++
gateways/kafka/src/server.rs | 896 +++++++++++++++++++
gateways/kafka/tests/api_handler_tests.rs | 989 +++++++++++++++++++++
gateways/kafka/tests/broker_advertise_tests.rs | 117 +++
gateways/kafka/tests/common/codec.rs | 292 ++++++
gateways/kafka/tests/common/fixtures.rs | 91 ++
.../kafka/tests/common/scope.rs | 26 +-
gateways/kafka/tests/common/server.rs | 68 ++
gateways/kafka/tests/common/tcp.rs | 258 ++++++
gateways/kafka/tests/common/wire.rs | 447 ++++++++++
.../kafka/tests/fixtures_canary_tests.rs | 36 +-
gateways/kafka/tests/golden_wire_fixtures_tests.rs | 122 +++
gateways/kafka/tests/header_tests.rs | 282 ++++++
gateways/kafka/tests/listener_robustness_tests.rs | 624 +++++++++++++
gateways/kafka/tests/response_negative_tests.rs | 277 ++++++
gateways/kafka/tests/server_e2e_tests.rs | 451 ++++++++++
gateways/kafka/tests/server_integration_tests.rs | 129 +++
gateways/kafka/tests/version_firewall_tests.rs | 799 +++++++++++++++++
.../kafka/tools/kafka-tool}/Cargo.toml | 20 +-
gateways/kafka/tools/kafka-tool/README.md | 251 ++++++
gateways/kafka/tools/kafka-tool/src/main.rs | 864 ++++++++++++++++++
gateways/kafka/tools/kafka-tool/src/response.rs | 389 ++++++++
.../tools/kafka-tool/tests/generate_cli_tests.rs | 82 ++
scripts/ci/coverage-baseline-affected.sh | 2 +-
54 files changed, 11432 insertions(+), 157 deletions(-)
create mode 100644 gateways/README.md
copy {core/bench => gateways/kafka}/Cargo.toml (54%)
create mode 100644 gateways/kafka/README.md
create mode 100644 gateways/kafka/docs/MANUAL_TESTING.md
create mode 100644 gateways/kafka/docs/SCOPE.md
create mode 100644 gateways/kafka/docs/TEST_SUITE.md
create mode 100644 gateways/kafka/docs/kafka_api_keys_reference.md
create mode 100755 gateways/kafka/scripts/ci-wire-fixtures.sh
create mode 100644 gateways/kafka/src/error.rs
copy bdd/rust/tests/steps/mod.rs => gateways/kafka/src/lib.rs (85%)
create mode 100644 gateways/kafka/src/main.rs
create mode 100644 gateways/kafka/src/protocol/api.rs
create mode 100644 gateways/kafka/src/protocol/bounds_guard.rs
create mode 100644 gateways/kafka/src/protocol/header.rs
copy {bdd/rust/tests/helpers => gateways/kafka/src/protocol}/mod.rs (91%)
create mode 100644 gateways/kafka/src/protocol/responses.rs
create mode 100644 gateways/kafka/src/server.rs
create mode 100644 gateways/kafka/tests/api_handler_tests.rs
create mode 100644 gateways/kafka/tests/broker_advertise_tests.rs
create mode 100644 gateways/kafka/tests/common/codec.rs
create mode 100644 gateways/kafka/tests/common/fixtures.rs
copy bdd/rust/tests/stream_crud.rs => gateways/kafka/tests/common/scope.rs
(60%)
create mode 100644 gateways/kafka/tests/common/server.rs
create mode 100644 gateways/kafka/tests/common/tcp.rs
create mode 100644 gateways/kafka/tests/common/wire.rs
copy foreign/csharp/Iggy_SDK_Tests/Utils/DummyObj/DummyObjFactory.cs =>
gateways/kafka/tests/fixtures_canary_tests.rs (51%)
create mode 100644 gateways/kafka/tests/golden_wire_fixtures_tests.rs
create mode 100644 gateways/kafka/tests/header_tests.rs
create mode 100644 gateways/kafka/tests/listener_robustness_tests.rs
create mode 100644 gateways/kafka/tests/response_negative_tests.rs
create mode 100644 gateways/kafka/tests/server_e2e_tests.rs
create mode 100644 gateways/kafka/tests/server_integration_tests.rs
create mode 100644 gateways/kafka/tests/version_firewall_tests.rs
copy {core/bench/runner => gateways/kafka/tools/kafka-tool}/Cargo.toml (73%)
create mode 100644 gateways/kafka/tools/kafka-tool/README.md
create mode 100644 gateways/kafka/tools/kafka-tool/src/main.rs
create mode 100644 gateways/kafka/tools/kafka-tool/src/response.rs
create mode 100644 gateways/kafka/tools/kafka-tool/tests/generate_cli_tests.rs
