This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch kafka-configs-regression
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 5f695fbf8 Merge branch 'master' into kafka-configs-regression
add 1e1278299 fix(partitions): fence install backup on writeback failure
(#4278)
add edb418bbe perf(gateways): give each Kafka producer its own Iggy client
(#4502)
add 0b12c8ae9 Merge branch 'master' into kafka-configs-regression
No new revisions were added by this update.
Summary of changes:
core/partitions/Cargo.toml | 2 +-
core/partitions/src/iggy_index_writer.rs | 13 +-
core/partitions/src/iggy_partition.rs | 141 +++-
core/partitions/src/install_backup.rs | 84 ++-
core/partitions/src/io.rs | 9 +-
core/partitions/src/lib.rs | 6 +-
core/partitions/src/messages_writer.rs | 13 +-
core/partitions/src/persistence.rs | 67 +-
core/partitions/src/state_transfer.rs | 25 +-
core/simulator/src/storage/tests.rs | 209 +++++-
gateways/kafka/README.md | 65 +-
gateways/kafka/docs/IDEMPOTENCE.md | 37 +-
gateways/kafka/docs/SCOPE.md | 7 +-
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 | 103 ++-
gateways/kafka/src/bridge/iggy_bridge/produce.rs | 819 ++++++++++++++++++---
gateways/kafka/src/bridge/mod.rs | 6 +-
gateways/kafka/src/main.rs | 43 +-
gateways/kafka/src/protocol/api.rs | 52 +-
.../src/protocol/handlers/init_producer_id.rs | 46 +-
gateways/kafka/src/protocol/handlers/mod.rs | 2 +-
gateways/kafka/src/protocol/handlers/produce.rs | 482 +++++++++++-
gateways/kafka/src/records.rs | 149 +++-
gateways/kafka/src/server.rs | 33 +-
.../kafka/tests/bridge_iggy_integration_tests.rs | 6 +-
gateways/kafka/tests/common/iggy_server.rs | 21 +-
gateways/kafka/tests/kafka_client_e2e_tests.rs | 3 +-
gateways/kafka/tests/produce_real_bridge_tests.rs | 190 ++++-
30 files changed, 2430 insertions(+), 343 deletions(-)