This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch feat/partition-routing
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 17391af80 fix(ci): tolerate unavailable job timing metadata
omit c0d4445e2 docs(consensus): clarify shared request ID history coverage
omit 3d1b10da8 fix(cli): preserve cluster metadata list column order
omit 23fac06d6 test(simulator): exercise stale owners and strict offsets
omit 1bd2d0d6e refactor(partitions): publish only planned emptied markers
omit bb9f77806 fix(server): refine consumer progress dispatch
omit c98e26680 fix(sdk): preserve routed admission and history freshness
omit 0dd5939c2 test(simulator): validate committed consumer state
omit 5a2e85e54 fix(server): preserve routing and recovery fences
omit f90c6c858 fix(message_bus): drain QUIC replies during shutdown
omit 48b320742 docs(cluster): describe routing compatibility changes
omit 51e607135 fix(cli): display replica IDs in cluster metadata
omit e247f1ef3 fix(sdk): keep inactive routing APIs private
omit e4b41305c fix(sdk): migrate partition routing to the PR4 protocol
omit ffd3098ab fix(simulator): avoid private links in public rustdoc
omit 94aa5de40 feat(server): route partition requests to their primaries
add c03409660 fix(bench): pace warmup and rewind consumers (#4314)
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 b669d9669 fix(gateways): stop reporting cleanup.policy and accept -1
defaults (#4534)
add 711550310 feat(server): route partition requests to their primaries
add b9ef6681d fix(simulator): avoid private links in public rustdoc
add e26a15fdf fix(sdk): migrate partition routing to the PR4 protocol
add c7034dba7 fix(sdk): keep inactive routing APIs private
add 68f8831d3 fix(cli): display replica IDs in cluster metadata
add 2e8f5b49b docs(cluster): describe routing compatibility changes
add 13ae7e18b fix(message_bus): drain QUIC replies during shutdown
add 57df5fc5d fix(server): preserve routing and recovery fences
add c9b9850a5 test(simulator): validate committed consumer state
add 4601d11e1 fix(sdk): preserve routed admission and history freshness
add 81a4f45da fix(server): refine consumer progress dispatch
add cd81e14ea refactor(partitions): publish only planned emptied markers
add 8d3154989 test(simulator): exercise stale owners and strict offsets
add 26c981ba7 fix(cli): preserve cluster metadata list column order
add 263517a56 docs(consensus): clarify shared request ID history coverage
add 312229948 fix(ci): tolerate unavailable job timing metadata
add d54da7a33 fix(server): close partition routing review gaps
add ebe761f12 test(partitions): initialize transfer empty marker
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (17391af80)
\
N -- N -- N refs/heads/feat/partition-routing (ebe761f12)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.github/workflows/pre-merge.yml | 16 +-
.../src/actors/consumer/benchmark_consumer.rs | 146 +++-
.../bench/src/actors/consumer/client/high_level.rs | 84 ++-
core/bench/src/actors/consumer/client/interface.rs | 4 +
core/bench/src/actors/consumer/client/low_level.rs | 60 ++
.../src/actors/producer/benchmark_producer.rs | 15 +-
.../benchmark_producing_consumer.rs | 38 +-
core/bench/src/args/common.rs | 6 +-
core/bench/src/utils/rate_limiter.rs | 261 ++++++-
core/consensus/src/impls.rs | 61 +-
core/consensus/src/plane_helpers.rs | 169 +++--
core/integration/tests/bench.rs | 190 +++++
core/journal/src/lib.rs | 13 +-
core/journal/src/prepare_journal.rs | 75 +-
core/partitions/Cargo.toml | 2 +-
core/partitions/src/iggy_index_writer.rs | 13 +-
core/partitions/src/iggy_partition.rs | 307 +++++++-
core/partitions/src/install_backup.rs | 84 ++-
core/partitions/src/io.rs | 9 +-
core/partitions/src/journal.rs | 21 +-
core/partitions/src/lib.rs | 6 +-
core/partitions/src/log.rs | 7 +-
core/partitions/src/messages_writer.rs | 13 +-
core/partitions/src/persistence.rs | 67 +-
core/partitions/src/state_transfer.rs | 25 +-
core/server/README.md | 16 +
core/server/src/dispatch/mod.rs | 110 ++-
core/server/src/http/forward.rs | 8 +
core/shard/src/lib.rs | 616 ++++++++--------
core/shard/src/partition_io.rs | 258 ++++++-
core/simulator/src/bin/workload-fuzz.rs | 7 +
core/simulator/src/deps.rs | 8 +-
core/simulator/src/lib.rs | 242 +++---
core/simulator/src/storage/tests.rs | 209 +++++-
core/simulator/src/workload/mod.rs | 59 ++
core/simulator/src/workload/shadow.rs | 13 +-
foreign/go/client/tcp/tcp_core.go | 3 +-
gateways/kafka/README.md | 65 +-
gateways/kafka/docs/CONFIGS.md | 31 +-
gateways/kafka/docs/IDEMPOTENCE.md | 37 +-
gateways/kafka/docs/MANUAL_TESTING.md | 4 +-
gateways/kafka/docs/SCOPE.md | 11 +-
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 +-
.../kafka/src/protocol/handlers/create_topics.rs | 125 +---
.../src/protocol/handlers/describe_configs.rs | 42 +-
.../src/protocol/handlers/init_producer_id.rs | 46 +-
gateways/kafka/src/protocol/handlers/mod.rs | 2 +-
gateways/kafka/src/protocol/handlers/produce.rs | 482 +++++++++++-
.../kafka/src/protocol/handlers/topic_config.rs | 55 +-
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/configs_java_client_tests.rs | 5 +-
gateways/kafka/tests/configs_real_bridge_tests.rs | 18 +-
.../kafka/tests/create_topics_real_bridge_tests.rs | 45 ++
gateways/kafka/tests/java/ConfigsProbe.java | 17 +-
gateways/kafka/tests/kafka_client_e2e_tests.rs | 3 +-
gateways/kafka/tests/produce_real_bridge_tests.rs | 190 ++++-
gateways/kafka/tests/response_negative_tests.rs | 11 +-
67 files changed, 4591 insertions(+), 1211 deletions(-)
