This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch fix/server-process-env-vars
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit da51d40a0 fix(configs): ignore the sibling binaries' path variables
omit fb1a3319a fix(configs): check server env vars once and refuse boot
only in debug
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)
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 14602e8ca fix(configs): check server env vars once and refuse boot
only in debug
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 (da51d40a0)
\
N -- N -- N refs/heads/fix/server-process-env-vars (14602e8ca)
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 +-
.github/actions/rust/pre-merge/action.yml | 7 +-
.github/config/components.yml | 1 +
.github/workflows/_test.yml | 2 +-
.github/workflows/pr-title.yml | 1 +
CONTRIBUTING.md | 4 +-
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 +-
bdd/java/build.gradle.kts | 6 +-
bdd/python/uv.lock | 38 +-
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 | 76 +-
.../configs/src/configs_impl/typed_env_provider.rs | 59 +-
core/configs/src/server_config/server.rs | 31 -
core/connectors/sinks/meilisearch_sink/src/lib.rs | 69 +-
core/consensus/src/plane_helpers.rs | 61 +-
core/journal/src/partition_journal.rs | 24 +
core/metadata/src/stm/result.rs | 13 +-
core/metadata/src/stm/stream.rs | 15 +-
core/metadata/src/stm/user.rs | 2 +-
core/partitions/src/persistence.rs | 128 +-
core/partitions/src/poll_plan.rs | 7 +
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 +++
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/README.md | 32 +-
foreign/java/gradle.properties | 2 +-
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 | 40 +
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 +-
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 | 71 +-
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 ++-
web/package-lock.json | 536 ++++----
web/package.json | 14 +-
97 files changed, 6240 insertions(+), 4306 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
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
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
