This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch kafka-gateway-perf
in repository https://gitbox.apache.org/repos/asf/iggy.git
from a460e5a93 Merge branch 'master' into kafka-gateway-perf
add ca96e78ce fix(gateways): address review comments on the Produce pool
No new revisions were added by this update.
Summary of changes:
gateways/kafka/README.md | 63 +-
gateways/kafka/docs/IDEMPOTENCE.md | 21 +-
gateways/kafka/docs/SCOPE.md | 4 +-
gateways/kafka/src/bridge/config.rs | 88 ++-
gateways/kafka/src/bridge/iggy_bridge/fetch.rs | 34 +-
.../kafka/src/bridge/iggy_bridge/group_offsets.rs | 18 +-
gateways/kafka/src/bridge/iggy_bridge/mod.rs | 96 ++-
gateways/kafka/src/bridge/iggy_bridge/produce.rs | 847 ++++++++++++++++-----
gateways/kafka/src/bridge/mod.rs | 4 +-
gateways/kafka/src/main.rs | 43 +-
gateways/kafka/src/protocol/api.rs | 27 +-
.../src/protocol/handlers/init_producer_id.rs | 46 +-
gateways/kafka/src/protocol/handlers/mod.rs | 2 +-
gateways/kafka/src/protocol/handlers/produce.rs | 362 ++++++---
gateways/kafka/src/records.rs | 119 ++-
gateways/kafka/src/server.rs | 33 +-
.../kafka/tests/bridge_iggy_integration_tests.rs | 6 +-
gateways/kafka/tests/common/iggy_server.rs | 5 +-
gateways/kafka/tests/kafka_client_e2e_tests.rs | 3 +-
gateways/kafka/tests/produce_real_bridge_tests.rs | 187 ++++-
20 files changed, 1581 insertions(+), 427 deletions(-)
