This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch kafka_gateway_leave_group
in repository https://gitbox.apache.org/repos/asf/iggy.git
from ca3d83967 address review
add 175aef6be address review commetns
add 20d323793 feat(gateways): Implement ListOffsets Kafka Keys backed by
Iggy bridge (#4259)
add 898caeef9 address review
add a131a2d32 chore(deps): Bump the java group across 1 directory with 5
updates (#4267)
add 85a397d0e chore(deps): Bump the python group across 3 directories with
2 updates (#4280)
add 5d8129e95 chore(deps): Bump the github-actions group across 1
directory with 5 updates (#4268)
add 6ac19040e docs(repo): add contributor guidance to AGENTS.md (#4286)
add 768ea8093 feat(gateways): SASL/PLAIN authentication for the Kafka
gateway (#4222)
add 9221034d7 Merge remote-tracking branch 'origin/master' into
kafka_gateway_group
add 57853b8ee Merge branch 'kafka_gateway_group' into
kafka_gateway_leave_group
No new revisions were added by this update.
Summary of changes:
.config/nextest.toml | 2 +-
.github/workflows/_common.yml | 6 +-
.github/workflows/_test.yml | 16 +-
.github/workflows/_test_examples.yml | 2 +-
.github/workflows/coverage-baseline.yml | 20 +-
.github/workflows/post-merge.yml | 2 +-
.github/workflows/publish.yml | 2 +-
AGENTS.md | 13 +-
Cargo.lock | 1 +
bdd/python/uv.lock | 64 +-
examples/python/pyproject.toml | 4 +-
examples/python/uv.lock | 68 +-
foreign/java/gradle/libs.versions.toml | 2 +-
foreign/python/uv.lock | 64 +-
gateways/kafka/Cargo.toml | 1 +
gateways/kafka/README.md | 78 +-
gateways/kafka/docs/AUTHENTICATION.md | 260 +++++
gateways/kafka/docs/CONSUMER_GROUPS.md | 19 +-
gateways/kafka/docs/MANUAL_TESTING.md | 68 +-
gateways/kafka/docs/SCOPE.md | 41 +-
gateways/kafka/docs/TEST_SUITE.md | 1 +
gateways/kafka/src/auth.rs | 606 +++++++++++
gateways/kafka/src/bridge/config.rs | 6 +-
gateways/kafka/src/bridge/iggy_bridge/mod.rs | 10 +-
gateways/kafka/src/env.rs | 64 ++
gateways/kafka/src/group/mod.rs | 64 +-
gateways/kafka/src/group/state.rs | 171 ++-
gateways/kafka/src/lib.rs | 2 +
gateways/kafka/src/main.rs | 120 ++-
gateways/kafka/src/protocol/api.rs | 220 +++-
gateways/kafka/src/protocol/bounds_guard.rs | 119 +++
.../kafka/src/protocol/handlers/api_versions.rs | 34 +-
.../src/protocol/handlers/find_coordinator.rs | 5 +-
gateways/kafka/src/protocol/handlers/join_group.rs | 9 +-
.../kafka/src/protocol/handlers/list_offsets.rs | 454 +++++++-
gateways/kafka/src/protocol/mod.rs | 1 +
gateways/kafka/src/protocol/sasl.rs | 573 ++++++++++
gateways/kafka/src/server.rs | 612 ++++++++++-
gateways/kafka/tests/common/scope.rs | 9 +-
gateways/kafka/tests/common/server.rs | 30 +-
gateways/kafka/tests/common/wire.rs | 1 -
gateways/kafka/tests/consumer_group_tests.rs | 8 +-
gateways/kafka/tests/golden_wire_fixtures_tests.rs | 8 +-
.../kafka/tests/list_offsets_real_bridge_tests.rs | 405 ++++++++
gateways/kafka/tests/listener_robustness_tests.rs | 34 +-
gateways/kafka/tests/sasl_tests.rs | 1097 ++++++++++++++++++++
gateways/kafka/tests/version_firewall_tests.rs | 2 +-
47 files changed, 5101 insertions(+), 297 deletions(-)
create mode 100644 gateways/kafka/docs/AUTHENTICATION.md
create mode 100644 gateways/kafka/src/auth.rs
create mode 100644 gateways/kafka/src/env.rs
create mode 100644 gateways/kafka/src/protocol/sasl.rs
create mode 100644 gateways/kafka/tests/list_offsets_real_bridge_tests.rs
create mode 100644 gateways/kafka/tests/sasl_tests.rs
