You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iggy.apache.org by hg...@apache.org on 2026/09/21 12:33:12 UTC
(iggy) branch feat/msg-bus-bufreadwrite updated (1c415713c -> 83539f52f)
This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch feat/msg-bus-bufreadwrite
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 1c415713c feat(message_bus): read replica sockets ahead, bypassing large frames
add 362bd7829 fix(server): note root password reset in generated password log (#4217)
add ad8951f57 chore(deps): Bump github.com/onsi/ginkgo/v2 from 2.32.1 to 2.32.2 in /bdd/go in the go group across 1 directory (#4227)
add 2ad0b1900 refactor(gateways): prepare the Kafka gateway for parallel handler work (#4228)
add 92aee83c4 fix(server): skip NUMA memory binding on a single-node host (#4243)
add 5d33f9d11 docs: refresh the README (#4208)
add ee226f971 refactor(server): split responses.rs by role and unify reply framing (#4089)
add 968a23e20 chore(java): start 0.9.1-SNAPSHOT and document the 0.9.0 SDK (#4247)
add 9a59f7857 ci(rust): run clippy on macOS so cfg(target_os) code gets linted (#4248)
add a69b4e36f fix(connectors): meilisearch_sink URL scheme check is case-sensitive (#4158)
add 41c6956bb fix(ci): retry flaky downloads and stop dry runs promising new tags (#4216)
add d1cb5aee7 fix(configs): check server env vars once and refuse boot only in debug (#4200)
add 9dbf84629 feat(message_bus): read replica sockets ahead, bypassing large frames
add 83539f52f docs(message_bus): correct the overstated read-ahead copy bound
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 (1c415713c)
\
N -- N -- N refs/heads/feat/msg-bus-bufreadwrite (83539f52f)
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:
.config/nextest.toml | 20 +-
.../actions/csharp-dotnet/post-merge/action.yml | 2 +-
.github/actions/java-gradle/post-merge/action.yml | 2 +-
.../actions/python-maturin/pre-merge/action.yml | 4 +-
.github/actions/rust/pre-merge/action.yml | 9 +-
.../actions/utils/setup-node-with-cache/action.yml | 2 +-
.../actions/utils/setup-rust-with-cache/action.yml | 17 +-
.../utils/validate-third-party-licenses/action.yml | 10 +-
.github/config/components.yml | 1 +
.github/workflows/_build_python_wheels.yml | 46 +-
.github/workflows/_build_rust_artifacts.yml | 4 +-
.github/workflows/_common.yml | 9 +-
.github/workflows/_detect.yml | 2 +-
.github/workflows/_publish_rust_crates.yml | 2 +-
.github/workflows/_test.yml | 2 +-
.github/workflows/coverage-baseline.yml | 4 +-
.github/workflows/post-merge.yml | 2 +-
.github/workflows/pre-merge.yml | 54 +-
.github/workflows/publish.yml | 127 +-
README.md | 104 +-
assets/cli.png | Bin 231092 -> 151099 bytes
assets/server.png | Bin 1176428 -> 756489 bytes
assets/web_ui.png | Bin 145001 -> 136258 bytes
bdd/go/go.mod | 2 +-
bdd/go/go.sum | 4 +-
core/binary_protocol/src/consensus/header.rs | 153 +++
core/binary_protocol/src/consensus/mod.rs | 5 +-
core/binary_protocol/src/consensus/reply_result.rs | 38 +-
core/binary_protocol/src/lib.rs | 13 +-
core/configs/src/configs_impl/file_provider.rs | 101 +-
.../configs/src/configs_impl/typed_env_provider.rs | 100 +-
core/configs/src/server_config/server.rs | 36 +-
core/connectors/sinks/meilisearch_sink/src/lib.rs | 69 +-
core/consensus/src/plane_helpers.rs | 61 +-
core/message_bus/src/framing.rs | 7 +-
core/message_bus/src/transports/tcp.rs | 2 +-
core/metadata/src/stm/result.rs | 13 +-
core/metadata/src/stm/stream.rs | 15 +-
core/metadata/src/stm/user.rs | 2 +-
core/server/config.toml | 24 +-
core/server/src/boot/credentials.rs | 4 +-
core/server/src/boot/mod.rs | 2 +-
core/server/src/consumer_group.rs | 2 +-
core/server/src/dispatch/authz.rs | 7 +-
core/server/src/dispatch/failure.rs | 463 ++++---
core/server/src/dispatch/mod.rs | 2 +-
core/server/src/dispatch/partition.rs | 6 +-
core/server/src/dispatch/reads.rs | 7 +-
core/server/src/dispatch/session_ops.rs | 2 +-
core/server/src/dispatch/submit.rs | 4 +-
core/server/src/http/handlers.rs | 5 +-
core/server/src/http/reads.rs | 26 +-
core/server/src/http/reply.rs | 9 +-
core/server/src/http/submit.rs | 2 +-
core/server/src/http/wire.rs | 2 +-
core/server/src/lib.rs | 3 +
core/server/src/namespace.rs | 362 ++++++
core/server/src/reply_frame.rs | 875 +++++++++++++
core/server/src/responses.rs | 1343 +-------------------
core/server/src/session_manager.rs | 2 +-
core/server/src/shard_allocator.rs | 44 +-
core/server/src/sysinfo_probe.rs | 151 +++
foreign/java/README.md | 32 +-
foreign/java/gradle.properties | 2 +-
gateways/kafka/README.md | 1 +
gateways/kafka/src/bridge/config.rs | 4 +-
gateways/kafka/src/bridge/iggy_bridge.rs | 529 --------
.../kafka/src/bridge/iggy_bridge/fetch.rs | 11 +-
gateways/kafka/src/bridge/iggy_bridge/mod.rs | 187 +++
gateways/kafka/src/bridge/iggy_bridge/offsets.rs | 176 +++
.../kafka/src/bridge/iggy_bridge/produce.rs | 11 +-
gateways/kafka/src/bridge/iggy_bridge/topics.rs | 220 ++++
gateways/kafka/src/main.rs | 81 +-
gateways/kafka/src/protocol/api.rs | 529 +-------
.../kafka/src/protocol/handlers/api_versions.rs | 107 ++
.../kafka/src/protocol/handlers/create_topics.rs | 130 ++
gateways/kafka/src/protocol/handlers/fetch.rs | 118 ++
.../kafka/src/protocol/handlers/list_offsets.rs | 115 ++
gateways/kafka/src/protocol/handlers/metadata.rs | 171 +++
gateways/kafka/src/protocol/handlers/mod.rs | 179 +++
gateways/kafka/src/protocol/handlers/produce.rs | 150 +++
gateways/kafka/src/protocol/mod.rs | 2 +-
gateways/kafka/src/protocol/responses.rs | 318 -----
gateways/kafka/src/server.rs | 40 +-
gateways/kafka/tests/api_handler_tests.rs | 200 +--
.../kafka/tests/bridge_iggy_integration_tests.rs | 398 +-----
gateways/kafka/tests/broker_advertise_tests.rs | 5 +-
gateways/kafka/tests/common/iggy_server.rs | 406 ++++++
gateways/kafka/tests/golden_wire_fixtures_tests.rs | 15 +-
gateways/kafka/tests/listener_robustness_tests.rs | 1 +
gateways/kafka/tests/response_negative_tests.rs | 42 +-
gateways/kafka/tests/server_e2e_tests.rs | 2 +-
gateways/kafka/tests/version_firewall_tests.rs | 148 ++-
scripts/prepare-release.sh | 1 +
94 files changed, 4900 insertions(+), 3822 deletions(-)
create mode 100644 core/server/src/namespace.rs
create mode 100644 core/server/src/reply_frame.rs
create mode 100644 core/server/src/sysinfo_probe.rs
delete mode 100644 gateways/kafka/src/bridge/iggy_bridge.rs
copy bdd/rust/tests/steps/mod.rs => gateways/kafka/src/bridge/iggy_bridge/fetch.rs (85%)
create mode 100644 gateways/kafka/src/bridge/iggy_bridge/mod.rs
create mode 100644 gateways/kafka/src/bridge/iggy_bridge/offsets.rs
copy bdd/rust/tests/steps/mod.rs => gateways/kafka/src/bridge/iggy_bridge/produce.rs (85%)
create mode 100644 gateways/kafka/src/bridge/iggy_bridge/topics.rs
create mode 100644 gateways/kafka/src/protocol/handlers/api_versions.rs
create mode 100644 gateways/kafka/src/protocol/handlers/create_topics.rs
create mode 100644 gateways/kafka/src/protocol/handlers/fetch.rs
create mode 100644 gateways/kafka/src/protocol/handlers/list_offsets.rs
create mode 100644 gateways/kafka/src/protocol/handlers/metadata.rs
create mode 100644 gateways/kafka/src/protocol/handlers/mod.rs
create mode 100644 gateways/kafka/src/protocol/handlers/produce.rs
delete mode 100644 gateways/kafka/src/protocol/responses.rs
create mode 100644 gateways/kafka/tests/common/iggy_server.rs