This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch benchmark/deferred-polling-task-per-partition
in repository https://gitbox.apache.org/repos/asf/iggy.git
discard d1472ea07 feat(message_bus): read replica sockets ahead into a buffer
discard 0da8329e4 fix(partitions): serve the prefix a byte-limited disk read
already holds
discard 391fb6643 fix(shard): charge a deferred poll for its reply, not its
borrows
discard 3959c3c62 fix(partitions): admit deferred polls regardless of journal
residency
discard b7c6f2c73 perf(partitions): keep shard traffic moving during file I/O
discard 097dde82d feat(java): add deferred polling to the TCP and HTTP clients
discard 5062aa958 feat(rust): make bounded long polling the consumer default
add de1a6fdd4 chore(deps): Bump the python group across 3 directories with
1 update (#4206)
add d8edf2fd0 chore(deps): Bump the java group across 3 directories with 5
updates (#4196)
add 4748a6540 docs: add the dev@ mailing list to the README and
CONTRIBUTING (#4189)
add bc092ce56 ci: allow the swift scope in PR titles (#4207)
add 1284e3044 fix(partitions): handle clippy with poll diagnostics
disabled (#4203)
add 13a0d9165 fix(partitions): account for segment-backed append batches
(#4202)
add b70be6ad7 chore(deps): Bump the web group across 1 directory with 6
updates (#4220)
add 63d97a66d docs(gateways): settle the Kafka record mapping, producer
ids, offsets (#4205)
add c1159864b chore(deps): Bump the node group across 2 directories with
14 updates (#4221)
add f5f4a9d4d chore(deps): Bump devalue from 5.8.1 to 5.9.2 in /web (#4223)
add 362bd7829 fix(server): note root password reset in generated password
log (#4217)
new 8cf4c9265 feat(rust): make bounded long polling the consumer default
new d20522372 feat(java): add deferred polling to the TCP and HTTP clients
new f2330fef3 perf(partitions): keep shard traffic moving during file I/O
new c4e8f56be fix(partitions): admit deferred polls regardless of journal
residency
new 3b726a65e fix(shard): charge a deferred poll for its reply, not its
borrows
new ca6da2d7e fix(partitions): serve the prefix a byte-limited disk read
already holds
new c73cb0878 feat(message_bus): read replica sockets ahead into a buffer
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 (d1472ea07)
\
N -- N -- N
refs/heads/benchmark/deferred-polling-task-per-partition (c73cb0878)
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.
The 7 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.github/workflows/pr-title.yml | 1 +
CONTRIBUTING.md | 4 +-
README.md | 2 +-
bdd/java/build.gradle.kts | 6 +-
bdd/python/uv.lock | 38 +--
core/journal/src/partition_journal.rs | 24 ++
core/partitions/src/persistence.rs | 128 +++++---
core/partitions/src/poll_plan.rs | 7 +
core/server/src/boot/credentials.rs | 4 +-
core/simulator/src/storage/tests.rs | 67 +++--
examples/java/build.gradle.kts | 4 +-
examples/node/package-lock.json | 166 +++++++---
examples/node/package.json | 2 +-
examples/python/pyproject.toml | 2 +-
examples/python/uv.lock | 40 +--
foreign/java/gradle/libs.versions.toml | 4 +-
foreign/node/package-lock.json | 479 +++++++++++++++++------------
foreign/node/package.json | 4 +-
foreign/python/uv.lock | 38 +--
gateways/kafka/README.md | 39 +++
gateways/kafka/docs/BRIDGE_MAPPING.md | 275 +++++++++++++++++
gateways/kafka/docs/IDEMPOTENCE.md | 179 +++++++++++
gateways/kafka/docs/OFFSET_STORAGE.md | 163 ++++++++++
gateways/kafka/docs/SCOPE.md | 12 +-
web/package-lock.json | 536 +++++++++++++++++++--------------
web/package.json | 14 +-
26 files changed, 1643 insertions(+), 595 deletions(-)
create mode 100644 gateways/kafka/docs/BRIDGE_MAPPING.md
create mode 100644 gateways/kafka/docs/IDEMPOTENCE.md
create mode 100644 gateways/kafka/docs/OFFSET_STORAGE.md
