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 0464f0fbe Merge branch 'master' into kafka-offsets
add a372113f2 docs(gateways): link the issue for the kind 3 upgrade check
add e73557e00 fix: address review comments
No new revisions were added by this update.
Summary of changes:
Cargo.lock | 1 +
core/server/src/dispatch/partition.rs | 79 ++++-
gateways/kafka/Cargo.toml | 1 +
gateways/kafka/README.md | 2 +
gateways/kafka/docs/OFFSET_STORAGE.md | 30 +-
gateways/kafka/docs/kafka_api_keys_reference.md | 8 +-
gateways/kafka/src/bridge/error.rs | 12 +-
gateways/kafka/src/bridge/iggy_bridge/fetch.rs | 6 +
.../kafka/src/bridge/iggy_bridge/group_offsets.rs | 323 ++++++++++++++-------
gateways/kafka/src/bridge/iggy_bridge/topics.rs | 25 +-
gateways/kafka/src/group/mod.rs | 34 ++-
gateways/kafka/src/group/state.rs | 60 +++-
gateways/kafka/src/protocol/api.rs | 23 +-
gateways/kafka/src/protocol/handlers/heartbeat.rs | 13 +-
gateways/kafka/src/protocol/handlers/mod.rs | 14 +-
.../kafka/src/protocol/handlers/offset_commit.rs | 26 +-
.../kafka/src/protocol/handlers/offset_fetch.rs | 135 +++++----
gateways/kafka/tests/common/wire.rs | 25 ++
gateways/kafka/tests/offsets_real_bridge_tests.rs | 125 ++++++--
19 files changed, 708 insertions(+), 234 deletions(-)
