This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch skill-review-command
in repository https://gitbox.apache.org/repos/asf/iggy.git
from a7691d969 feat(ci): add /skill review command that runs repo skills
add ad8951f57 chore(deps): Bump github.com/onsi/ginkgo/v2 from 2.32.1 to
2.32.2 in /bdd/go in the go group across 1 directory (#4227)
add 2ad0b1900 refactor(gateways): prepare the Kafka gateway for parallel
handler work (#4228)
add f1959f97d Merge branch 'master' into skill-review-command
No new revisions were added by this update.
Summary of changes:
.config/nextest.toml | 20 +-
bdd/go/go.mod | 2 +-
bdd/go/go.sum | 4 +-
gateways/kafka/README.md | 1 +
gateways/kafka/src/bridge/iggy_bridge.rs | 529 ---------------------
.../kafka/src/bridge/iggy_bridge/fetch.rs | 11 +-
gateways/kafka/src/bridge/iggy_bridge/mod.rs | 187 ++++++++
gateways/kafka/src/bridge/iggy_bridge/offsets.rs | 176 +++++++
.../kafka/src/bridge/iggy_bridge/produce.rs | 11 +-
gateways/kafka/src/bridge/iggy_bridge/topics.rs | 220 +++++++++
gateways/kafka/src/main.rs | 71 ++-
gateways/kafka/src/protocol/api.rs | 529 +++------------------
.../kafka/src/protocol/handlers/api_versions.rs | 107 +++++
.../kafka/src/protocol/handlers/create_topics.rs | 130 +++++
gateways/kafka/src/protocol/handlers/fetch.rs | 118 +++++
.../kafka/src/protocol/handlers/list_offsets.rs | 115 +++++
gateways/kafka/src/protocol/handlers/metadata.rs | 171 +++++++
gateways/kafka/src/protocol/handlers/mod.rs | 179 +++++++
gateways/kafka/src/protocol/handlers/produce.rs | 150 ++++++
gateways/kafka/src/protocol/mod.rs | 2 +-
gateways/kafka/src/protocol/responses.rs | 318 -------------
gateways/kafka/src/server.rs | 40 +-
gateways/kafka/tests/api_handler_tests.rs | 200 +++++---
.../kafka/tests/bridge_iggy_integration_tests.rs | 398 +---------------
gateways/kafka/tests/broker_advertise_tests.rs | 5 +-
gateways/kafka/tests/common/iggy_server.rs | 406 ++++++++++++++++
gateways/kafka/tests/golden_wire_fixtures_tests.rs | 15 +-
gateways/kafka/tests/listener_robustness_tests.rs | 1 +
gateways/kafka/tests/response_negative_tests.rs | 42 +-
gateways/kafka/tests/server_e2e_tests.rs | 2 +-
gateways/kafka/tests/version_firewall_tests.rs | 148 +++---
31 files changed, 2351 insertions(+), 1957 deletions(-)
delete mode 100644 gateways/kafka/src/bridge/iggy_bridge.rs
copy bdd/rust/tests/steps/mod.rs =>
gateways/kafka/src/bridge/iggy_bridge/fetch.rs (85%)
create mode 100644 gateways/kafka/src/bridge/iggy_bridge/mod.rs
create mode 100644 gateways/kafka/src/bridge/iggy_bridge/offsets.rs
copy bdd/rust/tests/steps/mod.rs =>
gateways/kafka/src/bridge/iggy_bridge/produce.rs (85%)
create mode 100644 gateways/kafka/src/bridge/iggy_bridge/topics.rs
create mode 100644 gateways/kafka/src/protocol/handlers/api_versions.rs
create mode 100644 gateways/kafka/src/protocol/handlers/create_topics.rs
create mode 100644 gateways/kafka/src/protocol/handlers/fetch.rs
create mode 100644 gateways/kafka/src/protocol/handlers/list_offsets.rs
create mode 100644 gateways/kafka/src/protocol/handlers/metadata.rs
create mode 100644 gateways/kafka/src/protocol/handlers/mod.rs
create mode 100644 gateways/kafka/src/protocol/handlers/produce.rs
delete mode 100644 gateways/kafka/src/protocol/responses.rs
create mode 100644 gateways/kafka/tests/common/iggy_server.rs
