This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch kafka-offsets
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 603b1031b Merge branch 'master' into kafka-offsets
add a85d90f11 fix: address review comments
No new revisions were added by this update.
Summary of changes:
core/common/src/traits/consumer_offset_client.rs | 1 +
core/server/src/dispatch/partition.rs | 23 +-
core/server/src/http/handlers.rs | 42 ++-
gateways/kafka/README.md | 6 +-
gateways/kafka/docs/CONSUMER_GROUPS.md | 2 +-
gateways/kafka/docs/OFFSET_STORAGE.md | 22 +-
gateways/kafka/src/bridge/iggy_bridge/fetch.rs | 23 +-
.../kafka/src/bridge/iggy_bridge/group_offsets.rs | 394 +++++++++++++--------
gateways/kafka/src/bridge/iggy_bridge/mod.rs | 19 +-
gateways/kafka/src/bridge/iggy_bridge/produce.rs | 9 +-
gateways/kafka/src/bridge/mod.rs | 3 +-
gateways/kafka/src/group/mod.rs | 4 +-
gateways/kafka/src/group/state.rs | 33 +-
.../kafka/src/protocol/handlers/offset_commit.rs | 13 +-
.../kafka/src/protocol/handlers/offset_fetch.rs | 71 ++--
15 files changed, 423 insertions(+), 242 deletions(-)
