This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch kafka_gateway_group
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 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)
new 9221034d7 Merge remote-tracking branch 'origin/master' into
kafka_gateway_group
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.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 | 58 ++
gateways/kafka/docs/AUTHENTICATION.md | 260 +++++
gateways/kafka/docs/MANUAL_TESTING.md | 64 ++
gateways/kafka/docs/SCOPE.md | 14 +-
gateways/kafka/docs/TEST_SUITE.md | 1 +
gateways/kafka/src/auth.rs | 606 +++++++++++
gateways/kafka/src/bridge/config.rs | 6 +-
gateways/kafka/src/env.rs | 64 ++
gateways/kafka/src/lib.rs | 2 +
gateways/kafka/src/main.rs | 120 ++-
gateways/kafka/src/protocol/api.rs | 207 +++-
gateways/kafka/src/protocol/bounds_guard.rs | 120 +++
.../kafka/src/protocol/handlers/api_versions.rs | 34 +-
gateways/kafka/src/protocol/mod.rs | 1 +
gateways/kafka/src/protocol/sasl.rs | 573 ++++++++++
gateways/kafka/src/server.rs | 605 ++++++++++-
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 | 1 +
gateways/kafka/tests/golden_wire_fixtures_tests.rs | 8 +-
.../kafka/tests/list_offsets_real_bridge_tests.rs | 1 +
gateways/kafka/tests/listener_robustness_tests.rs | 34 +-
gateways/kafka/tests/sasl_tests.rs | 1097 ++++++++++++++++++++
gateways/kafka/tests/version_firewall_tests.rs | 2 +-
39 files changed, 3967 insertions(+), 216 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/sasl_tests.rs
