This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch ci-nits
in repository https://gitbox.apache.org/repos/asf/iggy.git
from acbc00dc1 fix(ci): retry flaky downloads and stop dry runs promising
new tags
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 affe17ec2 Merge branch 'master' into ci-nits
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/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 +-
94 files changed, 6168 insertions(+), 4212 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
