This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch kafka_delete_records
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 24879c902 merge master
add 47731e34d feat(gateways): coordinate Kafka consumer groups (#4263)
add 3c2e7e8b5 chore(deps): Bump the web group across 1 directory with 5
updates (#4296)
add 89a794765 chore(deps): Bump @types/node from 26.5.1 to 26.6.1 in
/foreign/node in the node group across 1 directory (#4298)
add 2f6923905 feat(gateways): handle Kafka LeaveGroup for consumer groups
(#4270)
add 2a31cea28 merge master
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 1 +
foreign/node/package-lock.json | 9 +-
foreign/node/package.json | 2 +-
gateways/kafka/Cargo.toml | 10 +-
gateways/kafka/README.md | 10 +-
gateways/kafka/docs/CONSUMER_GROUPS.md | 191 ++
gateways/kafka/docs/MANUAL_TESTING.md | 20 +-
gateways/kafka/docs/SCOPE.md | 41 +-
gateways/kafka/docs/TEST_SUITE.md | 1 +
gateways/kafka/docs/kafka_api_keys_reference.md | 20 +-
gateways/kafka/scripts/ci-wire-fixtures.sh | 2 +-
gateways/kafka/src/group/mod.rs | 632 +++++
gateways/kafka/src/group/state.rs | 2956 ++++++++++++++++++++
gateways/kafka/src/lib.rs | 1 +
gateways/kafka/src/protocol/api.rs | 60 +-
gateways/kafka/src/protocol/bounds_guard.rs | 465 ++-
.../src/protocol/handlers/find_coordinator.rs | 169 ++
gateways/kafka/src/protocol/handlers/heartbeat.rs | 78 +
gateways/kafka/src/protocol/handlers/join_group.rs | 158 ++
.../kafka/src/protocol/handlers/leave_group.rs | 211 ++
gateways/kafka/src/protocol/handlers/mod.rs | 19 +-
gateways/kafka/src/protocol/handlers/sync_group.rs | 89 +
gateways/kafka/src/server.rs | 21 +-
gateways/kafka/tests/api_handler_tests.rs | 13 +-
gateways/kafka/tests/common/codec.rs | 11 +
gateways/kafka/tests/common/scope.rs | 11 +-
gateways/kafka/tests/common/wire.rs | 227 +-
gateways/kafka/tests/consumer_group_tests.rs | 1641 +++++++++++
.../kafka/tests/create_topics_real_bridge_tests.rs | 3 +
gateways/kafka/tests/golden_wire_fixtures_tests.rs | 65 +-
gateways/kafka/tests/idempotence_tests.rs | 11 +-
.../kafka/tests/list_offsets_real_bridge_tests.rs | 3 +
gateways/kafka/tests/listener_robustness_tests.rs | 8 +-
gateways/kafka/tests/metadata_real_bridge_tests.rs | 22 +-
gateways/kafka/tests/produce_real_bridge_tests.rs | 3 +
gateways/kafka/tests/server_e2e_tests.rs | 4 +-
gateways/kafka/tests/version_firewall_tests.rs | 53 +-
gateways/kafka/tools/kafka-tool/src/main.rs | 67 +-
web/package-lock.json | 40 +-
web/package.json | 10 +-
40 files changed, 7217 insertions(+), 141 deletions(-)
create mode 100644 gateways/kafka/docs/CONSUMER_GROUPS.md
create mode 100644 gateways/kafka/src/group/mod.rs
create mode 100644 gateways/kafka/src/group/state.rs
create mode 100644 gateways/kafka/src/protocol/handlers/find_coordinator.rs
create mode 100644 gateways/kafka/src/protocol/handlers/heartbeat.rs
create mode 100644 gateways/kafka/src/protocol/handlers/join_group.rs
create mode 100644 gateways/kafka/src/protocol/handlers/leave_group.rs
create mode 100644 gateways/kafka/src/protocol/handlers/sync_group.rs
create mode 100644 gateways/kafka/tests/consumer_group_tests.rs
