This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch kafka-empty-groups
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 82aed0ed7 address review
add 37b09c13f fix: address review
No new revisions were added by this update.
Summary of changes:
gateways/kafka/README.md | 15 +-
gateways/kafka/docs/AUTHENTICATION.md | 4 +-
gateways/kafka/docs/CONSUMER_GROUPS.md | 95 ++++--
gateways/kafka/docs/TEST_SUITE.md | 2 +-
.../kafka/src/bridge/iggy_bridge/group_index.rs | 245 ++++++++++---
.../kafka/src/bridge/iggy_bridge/group_offsets.rs | 378 ++++++++++++++-------
gateways/kafka/src/bridge/iggy_bridge/mod.rs | 5 +-
gateways/kafka/src/bridge/mod.rs | 4 +-
gateways/kafka/src/group/mod.rs | 103 ++++--
gateways/kafka/src/group/offset_work.rs | 153 ++++++---
gateways/kafka/src/group/state.rs | 81 +++--
gateways/kafka/src/protocol/api.rs | 5 +-
.../kafka/src/protocol/handlers/delete_groups.rs | 159 +++++++--
.../kafka/src/protocol/handlers/describe_groups.rs | 60 +++-
.../kafka/src/protocol/handlers/list_groups.rs | 92 ++++-
gateways/kafka/src/protocol/handlers/mod.rs | 3 +-
.../kafka/src/protocol/handlers/offset_commit.rs | 8 +-
.../kafka/src/protocol/handlers/offset_delete.rs | 88 ++++-
gateways/kafka/tests/common/wire.rs | 13 +-
.../kafka/tests/offset_groups_real_bridge_tests.rs | 340 ++++++++++++++++--
20 files changed, 1431 insertions(+), 422 deletions(-)
