This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch kafka_idempotence_stub
in repository https://gitbox.apache.org/repos/asf/iggy.git
from b64b2468c Merge branch 'master' into kafka_idempotence_stub
add 768ea8093 feat(gateways): SASL/PLAIN authentication for the Kafka
gateway (#4222)
add 2648bf5e7 merge master
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 1 +
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 | 15 +-
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 | 124 ++-
gateways/kafka/src/protocol/api.rs | 208 +++-
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/server.rs | 29 +-
gateways/kafka/tests/common/wire.rs | 1 -
gateways/kafka/tests/idempotence_tests.rs | 3 +-
.../kafka/tests/list_offsets_real_bridge_tests.rs | 1 +
gateways/kafka/tests/listener_robustness_tests.rs | 33 +-
gateways/kafka/tests/sasl_tests.rs | 1097 ++++++++++++++++++++
gateways/kafka/tests/version_firewall_tests.rs | 2 +-
25 files changed, 3827 insertions(+), 82 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
