This is an automated email from the ASF dual-hosted git repository.
kparisa pushed a change to branch feat/bigquery-sink
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 01b35178e fix(connectors): address remaining BigQuery review feedback
add 789c2e045 feat(gateways): answer OffsetCommit and OffsetFetch (#4415)
add 09420cf4d test(gateways): cover Kafka consumer groups end to end
(#4431)
add e1adb6ef3 Merge branch 'master' into feat/bigquery-sink
No new revisions were added by this update.
Summary of changes:
.config/nextest.toml | 1 +
.pr4372-comments.json | 0
Cargo.lock | 2 +
core/common/src/traits/consumer_offset_client.rs | 1 +
core/server/src/dispatch/partition.rs | 241 ++++++--
core/server/src/http/handlers.rs | 42 +-
gateways/kafka/Cargo.toml | 3 +
gateways/kafka/README.md | 75 ++-
gateways/kafka/docs/ACL_MAPPING.md | 5 +-
gateways/kafka/docs/CONSUMER_GROUPS.md | 24 +-
gateways/kafka/docs/MANUAL_TESTING.md | 20 +-
gateways/kafka/docs/OFFSET_STORAGE.md | 297 ++++-----
gateways/kafka/docs/SCOPE.md | 23 +-
gateways/kafka/docs/TEST_SUITE.md | 3 +-
gateways/kafka/docs/kafka_api_keys_reference.md | 14 +-
gateways/kafka/scripts/ci-wire-fixtures.sh | 2 +-
gateways/kafka/src/bridge/error.rs | 32 +-
gateways/kafka/src/bridge/iggy_bridge/fetch.rs | 33 +-
.../kafka/src/bridge/iggy_bridge/group_offsets.rs | 686 +++++++++++++++++++++
gateways/kafka/src/bridge/iggy_bridge/mod.rs | 29 +-
gateways/kafka/src/bridge/iggy_bridge/produce.rs | 9 +-
gateways/kafka/src/bridge/iggy_bridge/topics.rs | 25 +-
gateways/kafka/src/bridge/mod.rs | 12 +-
gateways/kafka/src/group/mod.rs | 68 +-
gateways/kafka/src/group/state.rs | 298 ++++++++-
gateways/kafka/src/protocol/api.rs | 39 +-
gateways/kafka/src/protocol/bounds_guard.rs | 264 +++++++-
gateways/kafka/src/protocol/handlers/heartbeat.rs | 13 +-
gateways/kafka/src/protocol/handlers/mod.rs | 38 +-
.../kafka/src/protocol/handlers/offset_commit.rs | 321 ++++++++++
.../kafka/src/protocol/handlers/offset_fetch.rs | 564 +++++++++++++++++
gateways/kafka/tests/common/scope.rs | 2 +
gateways/kafka/tests/common/wire.rs | 103 +++-
gateways/kafka/tests/golden_wire_fixtures_tests.rs | 16 +-
gateways/kafka/tests/kafka_client_e2e_tests.rs | 450 +++++++++++++-
gateways/kafka/tests/offsets_real_bridge_tests.rs | 364 +++++++++++
gateways/kafka/tests/server_e2e_tests.rs | 6 +-
gateways/kafka/tests/version_firewall_tests.rs | 16 +-
gateways/kafka/tools/kafka-tool/src/main.rs | 15 +-
39 files changed, 3767 insertions(+), 389 deletions(-)
delete mode 100644 .pr4372-comments.json
create mode 100644 gateways/kafka/src/bridge/iggy_bridge/group_offsets.rs
create mode 100644 gateways/kafka/src/protocol/handlers/offset_commit.rs
create mode 100644 gateways/kafka/src/protocol/handlers/offset_fetch.rs
create mode 100644 gateways/kafka/tests/offsets_real_bridge_tests.rs
