This is an automated email from the ASF dual-hosted git repository.
slbotbm pushed a change to branch connectors-team-review-skill
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 385dad3b6 fixes
omit d5b1d7f09 add more details to skill
omit 420a66fc0 add connector-review skill
add e9f3362e3 feat(connectors)!: add shared retry_async helper to the
connector SDK (#4104)
add d693eb93d test(integration): cleanup & drop the doris nextest
test-group (#4116)
add d75890f67 fix(repo): include gateways so the source release tarball
builds (#4126)
add e0027506f feat(cluster)!: let topics require durable acks and flatten
config (#4092)
add f87ef77c3 chore(deps): Bump js-yaml from 4.3.1 to 4.3.2 in
/foreign/node (#4107)
add e37396b1c chore(deps): Bump joi from 17.13.4 to 17.13.7 in /web (#4106)
add 73a0bed8b fix(consensus): count an unservable header as a nack (#4109)
add ff2e7481c fix(shard): refuse a frame no consensus plane claims (#4103)
add 91c3ca54b test(simulator): cover durability failures no existing test
can reach (#4132)
add dc2b38209 fix(integration): pull MinIO fixtures from quay instead of
Docker Hub (#4148)
add cfd3dff6a feat(cpp): add stream, topic, and partition functions to
high level client (#4022)
add ac5c7bf3a feat(connectors): add the HTTP source webhook gateway
connector (#3798)
add 309662d33 fix(ci): run integration tests when a binary they launch
changes (#4131)
add 6138eb9fd chore(deps): Bump the node group across 2 directories with 3
updates (#4125)
add 3b9320072 chore(deps): Bump github.com/klauspost/compress from 1.19.2
to 1.20.0 in /bdd/go in the go group across 1 directory (#4147)
add 2019e145d chore(deps): Bump the web group across 1 directory with 7
updates (#4124)
add dc54783f2 fix(server): resolve non-Linux clippy errors in shard
binding (#4144)
add 2b2e61253 fix(connectors): draw the retry delay inside the cap instead
of clamping (#4129)
add a4f38467b chore(deps): Bump the python group across 3 directories with
1 update (#4110)
add 262117cd1 perf(partitions): cut persisted-mode disk traffic per
acknowledgment (#4146)
add 67e14c26b fix(connectors): close the source instance a failed start
leaves behind (#4064)
add bb5ed1702 fix(server): preserve write responses and validate CLI input
(#4150)
add 9a4fd0f75 docs(integration): say that the test harness runs prebuilt
binaries (#4160)
add 585ab6922 fix(sdk): preserve consumer progress and client error
handling (#4151)
add bab0e331e fix(connectors): report failures and correct format
conversion (#4152)
add af237a124 fix(partitions): complete polls on the owning shard (#4119)
add 30bdb469b fix(configs): allow sibling IGGY variables (#4149)
add 2588e9926 feat(python): add high-level producer API (#4156)
add 78151b951 fix(ci): support multiline README commands (#4162)
add c2bd0c0cd fix(ci): don't mark PRs stale while they wait on review
(#4172)
add 1b4ebeecf fix(node): stop dropping and corrupting tokens in list
responses (#4171)
add 153088b3e fix(connectors): defer postgres source progress until ack
(#3957)
add e0a8196ef feat(python): expose update_user options (#4173)
add b68a506be fix(connectors): validate sink writes and startup readiness
(#4154)
add f239fca1e fix(connectors): defer source checkpoints and surface sink
failures (#4153)
add b4dd04ce2 fix(cluster): preserve group membership and reduce
produce/poll overhead (#4169)
add 7d0ee03ac chore(deps): Bump the csharp group with 5 updates (#4185)
add 90615962c chore(repo): refresh dependencies and strip edge versions
for 0.9.0 (#4187)
add f77d64b2f fix(server): distribute TCP-TLS and WSS connections across
shards (#4193)
add 71f29618b fix(cluster): prevent spurious heartbeat elections (#4194)
add 5c571cedd chore(deps): Bump the github-actions group with 2 updates
(#4197)
add 003cfe845 docs(node): fix "diclaimer" typo in README (#4188)
add 914bf23b7 feat(simulator): separate a vacuous run and assert through
the drain (#4191)
add 63362dc54 feat(gateways): Iggy Kafka bridge core — SDK client and
stream/topic mapping (#4043)
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 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 7bd69670f refactor(partitions): make purge recovery testable with
SimStorage (#4240)
add f0bd70283 perf(message_bus): batch small replica frames per socket
read (#4224)
add da4f3188d feat(cpp): add functions related to consumers and offsets to
high level client (#4180)
add ddbe222c2 chore(deps): Bump the csharp group with 11 updates (#4254)
add 74614ed05 feat(server): warn when listener binds loopback inside a
container (#4218)
add fa8070494 fix(cluster): stop partition repair asking for an inverted
op range (#4246)
add 2cacea5b1 fix(partitions): sync checkpoints through original writers
(#4253)
add 7bae8ec84 fix(connectors): tag sink batches with the payload's schema
(#4204)
add 2894368e1 feat(gateways): map Kafka records to Iggy messages and back
(#4229)
add 20d323793 feat(gateways): Implement ListOffsets Kafka Keys backed by
Iggy bridge (#4259)
add a131a2d32 chore(deps): Bump the java group across 1 directory with 5
updates (#4267)
add 85a397d0e chore(deps): Bump the python group across 3 directories with
2 updates (#4280)
add 5d8129e95 chore(deps): Bump the github-actions group across 1
directory with 5 updates (#4268)
add 6ac19040e docs(repo): add contributor guidance to AGENTS.md (#4286)
add 768ea8093 feat(gateways): SASL/PLAIN authentication for the Kafka
gateway (#4222)
add 1951e654c chore(integration): replace MinIO with Floci (#4290)
add b8bf85fd9 feat(swift): scaffold the Swift SDK package and CI lanes
(#4190)
add 8d0e28d9c feat(gateways): send Kafka records to Iggy from the Produce
handler (#4282)
add 15a49d082 feat(gateways): Implement CreateTopics and Metadata Kafka
Keys backed by the Iggy bridge (#4258)
add 3adf4fe39 docs: add how to report a bug found by an agent (#4309)
add 105ebe52f chore(deps): Bump rules_cc from 0.2.22 to 0.2.25 in
/foreign/cpp in the cpp group across 1 directory (#4310)
add e8cb28790 chore(deps): Bump the go group across 1 directory with 2
updates (#4300)
add d2f970661 fix(server): recover stalled consumer groups after restarts
(#4283)
add 11dd94c62 test(go): fail when a manual group commit on a split primary
drops membership (#4293)
add 8152a6074 feat(gateways): describe Iggy permissions as Kafka ACLs
(#4245)
add 32278f5dd refactor(server): move recovery readers to partitions, add
ShardHost (#4312)
add 91df1da99 feat(gateways): support idempotent Kafka producers, refuse
transactions (#4250)
add b2742e529 ci: resolve the PR triage trigger from the API, not the
artifact (#4257)
add 47731e34d feat(gateways): coordinate Kafka consumer groups (#4263)
add 3c2e7e8b5 chore(deps): Bump the web group across 1 directory with 5
updates (#4296)
add 89a794765 chore(deps): Bump @types/node from 26.5.1 to 26.6.1 in
/foreign/node in the node group across 1 directory (#4298)
add 2f6923905 feat(gateways): handle Kafka LeaveGroup for consumer groups
(#4270)
add 6cf56d631 feat(ci): add /skill review command that runs repo skills
(#4244)
add 096993f1b fix(ci): let committers with private org membership run PR
commands (#4319)
add e55e1208f feat(ci): set S-waiting-on-author when /skill review needs
the author (#4320)
add 929059e83 refactor!: remove the dead flush unsaved buffer command
(#4317)
add 17473ded1 fix(connectors): disable SELinux label checks for WireMock
test containers (#4265)
add e54da5ae2 docs(csharp): add simpler README for NuGet page (#4316)
add 325497196 test(go): cover system command serialization (#4305)
add 9aff4424a chore(deps): Bump the csharp group with 4 updates (#4323)
add 917612d27 feat(swift): add XXH3 and XXH32 with golden vectors from the
Rust crates (#4306)
add db63e0241 fix(partitions): reject queued offsets after history resets
(#4325)
add 81c26fcc3 feat(python): expose client disconnect and shutdown (#4288)
add ad20fc4a9 fix(ci): edit the Codecov PR comment once per run, not per
test leg (#4326)
add 4a94946da feat(cpp): add user manangement and client functions to high
level client (#4256)
add 285192450 fix(connectors): refuse http_source bodies Iggy cannot store
(#4302)
add caebce72a test(go): cover session and user command serialization
(#4334)
add 972486e79 docs(gateways): accept Kafka offset storage, document
DeleteRecords (#4289)
add 9fdb64274 test(integration): stop member drain test failing on slow
disks (#4341)
add 1f5d215b0 feat(connectors): Delta sink: production feasibility
improvements for S3 storage (#4219)
add 3a00b5ba1 feat(swift): add the domain models and their wire encodings
(#4335)
add 2206c4168 add connector-review skill
add 679e461e3 add more details to skill
add a1ef623e1 fixes
add 68c614769 fixes
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 (385dad3b6)
\
N -- N -- N refs/heads/connectors-team-review-skill (68c614769)
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:
.claude/skills/connector-review/SKILL.md | 237 +-
.claude/skills/connector-runtime/SKILL.md | 5 +-
.claude/skills/connector-sdk/SKILL.md | 23 +-
.claude/skills/connector-sink/SKILL.md | 5 +-
.claude/skills/connector-sink/TEMPLATE.md | 2 +-
.claude/skills/connector-source/SKILL.md | 85 +-
.claude/skills/connector-source/TEMPLATE.md | 49 +-
.claude/skills/connector-testing/SKILL.md | 51 +
.config/nextest.toml | 53 +-
.../actions/csharp-dotnet/post-merge/action.yml | 2 +-
.github/actions/go/pre-merge/action.yml | 8 +-
.github/actions/java-gradle/post-merge/action.yml | 2 +-
.github/actions/java-gradle/pre-merge/action.yml | 4 +-
.../actions/python-maturin/pre-merge/action.yml | 4 +-
.github/actions/rust/pre-merge/action.yml | 47 +-
.github/actions/swift/pre-merge/action.yml | 104 +
.../actions/utils/setup-node-with-cache/action.yml | 2 +-
.../actions/utils/setup-rust-with-cache/action.yml | 17 +-
.github/actions/utils/setup-swift/action.yml | 56 +
.../utils/validate-third-party-licenses/action.yml | 10 +-
.github/config/components.yml | 15 +-
.github/review-bot/README.md | 69 +
.github/review-bot/comment-style.md | 43 +
.github/review-bot/prompt.md | 73 +
.github/workflows/_build_python_wheels.yml | 46 +-
.github/workflows/_build_rust_artifacts.yml | 6 +-
.github/workflows/_common.yml | 17 +-
.github/workflows/_detect.yml | 13 +-
.github/workflows/_publish_rust_crates.yml | 2 +-
.github/workflows/_test.yml | 36 +-
.github/workflows/_test_examples.yml | 12 +-
.github/workflows/codecov-notify.yml | 54 +
.github/workflows/coverage-baseline.yml | 26 +-
.github/workflows/post-merge.yml | 4 +-
.github/workflows/pr-skill-review-post.yml | 504 ++
.github/workflows/pr-skill-review-run.yml | 542 ++
.github/workflows/pr-title.yml | 1 +
.github/workflows/pr-triage-apply.yml | 257 +-
.github/workflows/pr-triage-collect.yml | 6 +-
.github/workflows/pre-merge.yml | 77 +-
.github/workflows/publish.yml | 129 +-
.github/workflows/stale-prs-unmark-on-activity.yml | 101 +-
.github/workflows/stale-prs.yml | 4 +-
.gitignore | 10 +
.typos.toml | 2 +
AGENTS.md | 21 +-
CONTRIBUTING.md | 20 +-
Cargo.lock | 1439 ++---
Cargo.toml | 58 +-
README.md | 148 +-
assets/cli.png | Bin 231092 -> 151099
bytes
assets/server.png | Bin 1176428 -> 756489
bytes
assets/web_ui.png | Bin 145001 -> 136258
bytes
.../features/step_definitions/background_steps.cpp | 3 +-
.../features/step_definitions/messaging_steps.cpp | 31 +-
bdd/docker-compose.cluster.yml | 5 +-
bdd/docker-compose.server.yml | 2 +-
bdd/go/go.mod | 6 +-
bdd/go/go.sum | 12 +-
bdd/java/build.gradle.kts | 6 +-
bdd/python/uv.lock | 66 +-
codecov.yml | 5 +
core/ai/mcp/Cargo.toml | 2 +-
core/ai/mcp/README.md | 45 +-
core/ai/mcp/src/error.rs | 4 +
core/ai/mcp/src/log.rs | 167 +-
core/ai/mcp/src/main.rs | 118 +-
core/ai/mcp/src/service/mod.rs | 20 +-
core/ai/mcp/src/service/requests.rs | 4 +-
core/ai/mcp/src/systemd.rs | 2 +-
core/bench/Cargo.toml | 3 +-
core/bench/README.md | 60 +
core/bench/dashboard/frontend/Cargo.toml | 2 +-
core/bench/dashboard/frontend/index.html | 2 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/bench/report/Cargo.toml | 2 +-
core/bench/src/args/common.rs | 31 +-
core/bench/src/args/defaults.rs | 6 +-
core/bench/src/args/examples.rs | 355 +-
.../kinds/balanced/producer_and_consumer_group.rs | 4 +-
.../kinds/end_to_end/producing_consumer_group.rs | 2 +-
core/bench/src/args/kinds/pinned/consumer.rs | 6 +-
core/bench/src/args/transport.rs | 21 +-
core/bench/src/benchmarks/benchmark.rs | 9 +-
core/bench/src/benchmarks/common.rs | 4 +-
core/bench/src/utils/mod.rs | 130 +-
core/binary_protocol/Cargo.toml | 2 +-
core/binary_protocol/src/codes.rs | 31 +-
core/binary_protocol/src/consensus/command.rs | 11 +-
.../src/consensus/consumer_session.rs | 218 +
core/binary_protocol/src/consensus/header.rs | 202 +-
core/binary_protocol/src/consensus/mod.rs | 11 +-
core/binary_protocol/src/consensus/operation.rs | 42 +-
core/binary_protocol/src/consensus/reply_result.rs | 38 +-
core/binary_protocol/src/consensus/request.rs | 143 +
core/binary_protocol/src/dispatch.rs | 203 +-
core/binary_protocol/src/lib.rs | 13 +-
core/binary_protocol/src/primitives/options.rs | 27 +-
.../src/requests/consumer_offsets/mod.rs | 62 +
.../src/requests/messages/flush_unsaved_buffer.rs | 155 -
core/binary_protocol/src/requests/messages/mod.rs | 2 -
.../src/requests/system/attach_consumer_session.rs | 87 +
core/binary_protocol/src/requests/system/mod.rs | 2 +
.../src/requests/topics/update_topic.rs | 14 +-
core/binary_protocol/src/responses/messages/mod.rs | 2 +
.../src/responses/messages/poll_routing.rs | 95 +
.../src/responses/messages/send_messages.rs | 16 +-
core/binary_protocol/src/version.rs | 4 +-
core/cli/Cargo.toml | 2 +-
core/cli/src/args/consumer_group.rs | 8 +-
core/cli/src/args/consumer_offset.rs | 4 +-
core/cli/src/args/message.rs | 77 +-
core/cli/src/args/mod.rs | 4 +-
core/cli/src/args/personal_access_token.rs | 4 +-
core/cli/src/args/segment.rs | 37 +-
core/cli/src/args/stream.rs | 4 +-
core/cli/src/args/system.rs | 2 +-
core/cli/src/args/topic.rs | 99 +-
.../src/commands/binary_message/flush_messages.rs | 90 -
core/cli/src/commands/binary_message/mod.rs | 1 -
.../src/commands/binary_message/send_messages.rs | 23 +-
.../cli/src/commands/binary_topics/create_topic.rs | 10 +-
core/cli/src/main.rs | 13 +-
core/common/Cargo.toml | 2 +-
core/common/src/consumer_group_client_state.rs | 3 +-
.../src/http/messages/flush_unsaved_buffer.rs | 24 -
core/common/src/http/messages/mod.rs | 1 -
core/common/src/http/messages/poll_messages.rs | 4 +
.../src/traits/binary_impls/consumer_offsets.rs | 4 +-
core/common/src/traits/binary_impls/messages.rs | 44 +-
core/common/src/traits/binary_impls/users.rs | 3 +
core/common/src/traits/binary_transport.rs | 38 +-
core/common/src/traits/client.rs | 2 +-
core/common/src/traits/consumer_offset_client.rs | 4 +
core/common/src/traits/message_client.rs | 46 +-
core/common/src/traits/segment_client.rs | 7 +-
core/common/src/types/args/mod.rs | 6 +-
.../configuration/tcp_config/tcp_client_config.rs | 2 +-
core/common/src/types/message/partitioning.rs | 12 +-
core/common/src/types/message/partitioning_kind.rs | 4 +-
core/common/src/types/message/polling_strategy.rs | 7 +-
.../{cluster/role.rs => options/durability.rs} | 47 +-
core/common/src/types/options/mod.rs | 326 +-
core/common/src/wire_conversions.rs | 15 +
core/configs/Cargo.toml | 3 +
core/configs/src/common/defaults.rs | 100 +-
core/configs/src/common/displays.rs | 56 +-
core/configs/src/common/mod.rs | 2 +-
core/configs/src/common/server.rs | 9 +-
core/configs/src/common/system.rs | 222 +-
core/configs/src/common/validators.rs | 40 +-
core/configs/src/configs_impl/file_provider.rs | 239 +-
core/configs/src/configs_impl/mod.rs | 2 +-
.../configs/src/configs_impl/typed_env_provider.rs | 103 +-
core/configs/src/lib.rs | 2 +-
core/configs/src/server_config/defaults.rs | 20 +-
core/configs/src/server_config/displays.rs | 27 +-
core/configs/src/server_config/message_bus.rs | 164 +-
core/configs/src/server_config/partition.rs | 105 +-
core/configs/src/server_config/server.rs | 227 +-
core/configs/src/server_config/sharding.rs | 103 +-
core/configs/src/server_config/validators.rs | 456 +-
core/connectors/README.md | 49 +-
core/connectors/runtime/Cargo.toml | 6 +-
core/connectors/runtime/README.md | 56 +-
.../connectors/http_source_github.toml | 60 +
.../connectors/http_source_partner.toml | 55 +
.../example_config/connectors/quickwit_sink.toml | 2 +-
core/connectors/runtime/src/benchmark.rs | 5 +-
core/connectors/runtime/src/log.rs | 117 +-
core/connectors/runtime/src/main.rs | 27 +-
core/connectors/runtime/src/manager/sink.rs | 55 +-
core/connectors/runtime/src/manager/source.rs | 301 +-
core/connectors/runtime/src/metrics.rs | 36 +-
core/connectors/runtime/src/sink.rs | 686 ++-
core/connectors/runtime/src/source.rs | 431 +-
core/connectors/runtime/src/state.rs | 2 +-
core/connectors/runtime/src/state/http.rs | 70 +-
core/connectors/runtime/src/stream.rs | 47 +-
core/connectors/sdk/Cargo.toml | 7 +-
core/connectors/sdk/README.md | 298 +-
core/connectors/sdk/src/decoders/proto.rs | 136 +-
core/connectors/sdk/src/encoders/proto.rs | 206 +-
core/connectors/sdk/src/lib.rs | 336 +-
core/connectors/sdk/src/retry.rs | 654 ++-
core/connectors/sdk/src/sink.rs | 156 +-
core/connectors/sdk/src/source.rs | 184 +-
core/connectors/sdk/src/transforms/avro_convert.rs | 48 +-
.../connectors/sdk/src/transforms/filter_fields.rs | 6 +-
.../sdk/src/transforms/flatbuffer_convert.rs | 23 +-
.../sdk/src/transforms/json/filter_fields.rs | 53 +
.../connectors/sdk/src/transforms/proto_convert.rs | 264 +-
core/connectors/sdk/tests/protobuf_integration.rs | 683 ++-
core/connectors/sinks/README.md | 8 +
core/connectors/sinks/clickhouse_sink/Cargo.toml | 2 +-
core/connectors/sinks/clickhouse_sink/README.md | 50 +-
core/connectors/sinks/clickhouse_sink/config.toml | 13 +-
.../connectors/sinks/clickhouse_sink/src/binary.rs | 273 +-
core/connectors/sinks/clickhouse_sink/src/body.rs | 110 +-
.../connectors/sinks/clickhouse_sink/src/client.rs | 4 +-
core/connectors/sinks/delta_sink/Cargo.toml | 5 +-
core/connectors/sinks/delta_sink/README.md | 203 +-
core/connectors/sinks/delta_sink/config.toml | 2 +-
core/connectors/sinks/delta_sink/src/lib.rs | 1 +
core/connectors/sinks/delta_sink/src/sink.rs | 146 +-
core/connectors/sinks/delta_sink/src/storage.rs | 74 +-
core/connectors/sinks/doris_sink/Cargo.toml | 2 +-
core/connectors/sinks/doris_sink/README.md | 33 +-
core/connectors/sinks/doris_sink/config.toml | 1 -
core/connectors/sinks/doris_sink/src/lib.rs | 152 +-
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 5 +-
core/connectors/sinks/elasticsearch_sink/README.md | 9 +-
.../sinks/elasticsearch_sink/config.toml | 4 +-
.../connectors/sinks/elasticsearch_sink/src/lib.rs | 612 +-
core/connectors/sinks/http_sink/Cargo.toml | 2 +-
core/connectors/sinks/http_sink/README.md | 116 +-
core/connectors/sinks/http_sink/config.toml | 2 +-
core/connectors/sinks/http_sink/src/lib.rs | 42 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +-
core/connectors/sinks/iceberg_sink/README.md | 69 +-
core/connectors/sinks/iceberg_sink/src/lib.rs | 41 +
.../iceberg_sink/src/router/dynamic_router.rs | 58 +-
.../sinks/iceberg_sink/src/router/mod.rs | 43 +-
core/connectors/sinks/iceberg_sink/src/sink.rs | 10 +
core/connectors/sinks/influxdb_sink/Cargo.toml | 2 +-
core/connectors/sinks/influxdb_sink/README.md | 93 +-
.../connectors/sinks/influxdb_sink/dependencies.md | 4 +-
core/connectors/sinks/influxdb_sink/src/lib.rs | 87 +-
.../connectors/sinks/influxdb_sink/src/protocol.rs | 30 +-
core/connectors/sinks/meilisearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/meilisearch_sink/README.md | 63 +-
core/connectors/sinks/meilisearch_sink/src/lib.rs | 149 +-
core/connectors/sinks/mongodb_sink/Cargo.toml | 2 +-
core/connectors/sinks/mongodb_sink/README.md | 74 +-
core/connectors/sinks/mongodb_sink/src/lib.rs | 9 -
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +-
core/connectors/sinks/postgres_sink/README.md | 108 +-
core/connectors/sinks/postgres_sink/src/lib.rs | 159 +-
core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +-
core/connectors/sinks/quickwit_sink/README.md | 28 +-
core/connectors/sinks/quickwit_sink/config.toml | 2 +-
core/connectors/sinks/quickwit_sink/src/lib.rs | 274 +-
core/connectors/sinks/rabbitmq_sink/Cargo.toml | 2 +-
core/connectors/sinks/rabbitmq_sink/src/lib.rs | 14 +-
core/connectors/sinks/redshift_sink/Cargo.toml | 2 +-
core/connectors/sinks/redshift_sink/README.md | 2 +-
core/connectors/sinks/s3_sink/Cargo.toml | 3 +-
core/connectors/sinks/s3_sink/README.md | 69 +-
core/connectors/sinks/s3_sink/src/buffer.rs | 10 +
core/connectors/sinks/s3_sink/src/client.rs | 15 -
core/connectors/sinks/s3_sink/src/formatter.rs | 84 +-
core/connectors/sinks/s3_sink/src/sink.rs | 497 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
core/connectors/sinks/surrealdb_sink/Cargo.toml | 2 +-
core/connectors/sinks/surrealdb_sink/README.md | 110 +-
core/connectors/sinks/surrealdb_sink/config.toml | 1 -
core/connectors/sinks/surrealdb_sink/src/lib.rs | 34 +-
core/connectors/sources/README.md | 5 +-
.../sources/elasticsearch_source/Cargo.toml | 6 +-
.../sources/elasticsearch_source/README.md | 335 +-
.../sources/elasticsearch_source/config.toml | 2 +-
.../sources/elasticsearch_source/src/lib.rs | 337 +-
.../elasticsearch_source/src/state_manager.rs | 40 +-
.../delta_sink => sources/http_source}/Cargo.toml | 23 +-
core/connectors/sources/http_source/README.md | 383 ++
core/connectors/sources/http_source/config.toml | 68 +
core/connectors/sources/http_source/src/auth.rs | 464 ++
core/connectors/sources/http_source/src/lib.rs | 2539 +++++++++
.../sources/http_source/src/management.rs | 1535 +++++
core/connectors/sources/http_source/src/metrics.rs | 497 ++
core/connectors/sources/http_source/src/routes.rs | 666 +++
core/connectors/sources/http_source/src/server.rs | 3168 +++++++++++
core/connectors/sources/http_source/src/state.rs | 1437 +++++
core/connectors/sources/http_source/src/types.rs | 275 +
core/connectors/sources/influxdb_source/Cargo.toml | 2 +-
core/connectors/sources/influxdb_source/README.md | 108 +-
.../connectors/sources/influxdb_source/config.toml | 10 +-
.../sources/influxdb_source/dependencies.md | 4 +-
.../sources/influxdb_source/src/common.rs | 22 +-
core/connectors/sources/influxdb_source/src/lib.rs | 311 +-
core/connectors/sources/influxdb_source/src/row.rs | 112 +-
core/connectors/sources/influxdb_source/src/v2.rs | 16 +-
core/connectors/sources/influxdb_source/src/v3.rs | 114 +-
core/connectors/sources/postgres_source/Cargo.toml | 5 +-
core/connectors/sources/postgres_source/README.md | 294 +-
.../connectors/sources/postgres_source/config.toml | 4 +-
core/connectors/sources/postgres_source/src/lib.rs | 1941 ++++++-
core/connectors/sources/random_source/Cargo.toml | 2 +-
core/connectors/sources/random_source/README.md | 10 +-
core/connectors/sources/random_source/src/lib.rs | 31 +-
core/consensus/src/client_table.rs | 114 +
core/consensus/src/dvc_merge.rs | 86 +-
core/consensus/src/impls.rs | 645 ++-
core/consensus/src/plane_helpers.rs | 440 +-
core/cpu_allocation/src/lib.rs | 4 +-
core/harness_derive/src/attrs.rs | 2 +-
core/integration/Cargo.toml | 2 +
core/integration/src/bench_utils.rs | 2 +-
core/integration/src/harness/config/resolve.rs | 40 +-
core/integration/src/harness/disk.rs | 13 +-
.../src/harness/handle/connectors_runtime.rs | 16 +-
core/integration/src/harness/handle/server.rs | 24 +-
.../src/harness/orchestrator/builder.rs | 4 +-
core/integration/src/harness/seeds.rs | 8 +-
core/integration/tests/bench.rs | 114 +
.../test_consumer_group_create_command.rs | 38 +-
.../test_consumer_group_help_command.rs | 2 +-
.../test_consumer_offset_get_command.rs | 4 +-
.../test_consumer_offset_set_command.rs | 4 +-
.../tests/cli/general/test_help_command.rs | 8 +-
core/integration/tests/cli/message/mod.rs | 1 -
.../cli/message/test_message_flush_command.rs | 271 -
.../tests/cli/message/test_message_help_command.rs | 7 +-
.../tests/cli/message/test_message_send_command.rs | 44 +-
.../test_pat_create_command.rs | 4 +-
.../tests/cli/stream/test_stream_create_command.rs | 6 +-
.../tests/cli/system/test_me_command.rs | 2 +-
.../tests/cli/system/test_snapshot_cmd.rs | 2 +-
.../tests/cli/topic/test_topic_create_command.rs | 44 +-
.../tests/cli/topic/test_topic_update_command.rs | 20 +-
.../tests/cluster/client_table_restart.rs | 486 +-
core/integration/tests/cluster/crash_durability.rs | 382 +-
.../tests/cluster/crash_recovery_corruption.rs | 229 +-
.../tests/cluster/failover_client_continuity.rs | 2 +-
.../tests/cluster/fast_primary_rejoin.rs | 11 +-
.../tests/cluster/metadata_checkpoint_restart.rs | 2 +-
core/integration/tests/cluster/mod.rs | 1 +
.../cluster/multi_shard_partition_convergence.rs | 4 +-
.../tests/cluster/parked_frame_redispatch.rs | 8 +-
core/integration/tests/cluster/partition_dedup.rs | 12 +-
.../tests/cluster/partition_primary_routing.rs | 844 ++-
.../tests/cluster/partition_state_transfer.rs | 6 +-
.../tests/cluster/register_forwarding.rs | 16 +-
.../tests/cluster/replica_read_batching.rs | 150 +
.../tests/cluster/staggered_bootstrap.rs | 49 +-
core/integration/tests/config_provider/mod.rs | 6 +-
.../integration/tests/connectors/clickhouse/mod.rs | 2 +
.../tests/connectors/clickhouse/proto_text.rs | 113 +
.../sink.toml => clickhouse/proto_text.toml} | 2 +-
.../proto_text_config}/clickhouse_sink.toml | 43 +-
.../tests/connectors/delta/delta_sink.rs | 118 +-
.../delta/malformed_table_uri_config}/config.toml | 13 +-
.../{sink.toml => malformed_table_uri_sink.toml} | 2 +-
.../missing_secret_key_config/config.toml} | 18 +-
.../{sink.toml => missing_secret_key_sink.toml} | 2 +-
core/integration/tests/connectors/doris/mod.rs | 1 +
.../meilisearch_sink.rs => doris/proto_text.rs} | 56 +-
.../{delta/sink.toml => doris/proto_text.toml} | 2 +-
.../doris/proto_text_config/doris_sink.toml | 64 +
.../connectors/elasticsearch/elasticsearch_sink.rs | 79 +
.../tests/connectors/elasticsearch/mod.rs | 1 +
.../tests/connectors/elasticsearch/proto_text.rs | 126 +
.../sink.toml => elasticsearch/proto_text.toml} | 2 +-
.../proto_text_config/elasticsearch_sink.toml} | 27 +-
.../tests/connectors/fixtures/delta/fixture.rs | 288 +-
.../tests/connectors/fixtures/delta/mod.rs | 5 +-
.../integration/tests/connectors/fixtures/floci.rs | 160 +
.../tests/connectors/fixtures/http/container.rs | 29 +
.../tests/connectors/fixtures/http/mod.rs | 5 +
.../tests/connectors/fixtures/http/source.rs | 125 +
.../tests/connectors/fixtures/iceberg/container.rs | 166 +-
core/integration/tests/connectors/fixtures/mod.rs | 27 +-
.../tests/connectors/fixtures/mongodb/sink.rs | 2 -
.../tests/connectors/fixtures/postgres/cdc.rs | 41 +
.../tests/connectors/fixtures/postgres/mod.rs | 13 +-
.../tests/connectors/fixtures/postgres/sink.rs | 36 +
.../tests/connectors/fixtures/postgres/source.rs | 361 +-
.../connectors/fixtures/redshift/container.rs | 73 +-
.../tests/connectors/fixtures/redshift/mod.rs | 2 +-
.../tests/connectors/fixtures/redshift/sink.rs | 203 +-
.../tests/connectors/fixtures/s3/fixture.rs | 145 +-
.../tests/connectors/fixtures/surrealdb/mod.rs | 4 +-
.../tests/connectors/fixtures/surrealdb/sink.rs | 52 +-
.../tests/connectors/fixtures/wiremock.rs | 6 +
.../integration/tests/connectors/http/http_sink.rs | 124 +-
.../tests/connectors/http/http_source.rs | 622 ++
core/integration/tests/connectors/http/mod.rs | 3 +
.../tests/connectors/{random => http}/source.toml | 2 +-
.../http/source_config/http_github.toml} | 41 +-
.../http/source_config/http_partner.toml} | 37 +-
.../tests/connectors/influxdb/influxdb_sink.rs | 6 +-
.../tests/connectors/mongodb/mongodb_sink.rs | 10 +-
core/integration/tests/connectors/postgres/mod.rs | 58 +-
.../tests/connectors/postgres/postgres_sink.rs | 136 +-
.../tests/connectors/postgres/postgres_source.rs | 757 ++-
.../connectors/postgres/postgres_source_cdc.rs | 342 +-
.../tests/connectors/postgres/restart.rs | 3 +-
.../tests/connectors/random/random_source.rs | 120 +-
.../tests/connectors/runtime/error_isolation.rs | 82 +-
.../tests/connectors/runtime/http_state.rs | 32 +-
core/integration/tests/connectors/runtime/mod.rs | 1 +
.../tests/connectors/runtime/schema_tagging.rs | 134 +
.../sink.toml => runtime/schema_tagging.toml} | 2 +-
.../stdout_sink.toml} | 15 +-
...nvalid_state.toml => sink_transform_error.toml} | 2 +-
.../stdout.toml} | 26 +-
core/integration/tests/connectors/s3/s3_sink.rs | 41 +-
.../tests/connectors/surrealdb/surrealdb_sink.rs | 33 +-
core/integration/tests/data_integrity/mod.rs | 10 +-
.../tests/data_integrity/storage_compat.rs | 228 +-
.../verify_cluster_replica_data_identical.rs | 2 +-
core/integration/tests/mcp/mod.rs | 221 +-
core/integration/tests/mod.rs | 1 +
core/integration/tests/sdk/consumer_offset.rs | 61 +
core/integration/tests/sdk/options.rs | 15 +-
core/integration/tests/server/a2a_jwt/config.toml | 33 +-
.../tests/server/cluster_metadata_vsr.rs | 2 +-
.../tests/server/cluster_view_durability_vsr.rs | 2 +-
core/integration/tests/server/flush_vsr.rs | 69 -
.../tests/server/http_read_your_writes.rs | 4 +-
core/integration/tests/server/http_view_header.rs | 4 +-
core/integration/tests/server/http_vsr.rs | 158 +-
core/integration/tests/server/message_retrieval.rs | 2 +-
core/integration/tests/server/mod.rs | 3 +-
.../tests/server/partition_view_durability_vsr.rs | 2 +-
.../server/scenarios/authentication_scenario.rs | 56 +-
.../concurrent_produce_consume_scenario.rs | 2 +-
...h_multiple_clients_polling_messages_scenario.rs | 6 +-
.../tests/server/scenarios/encryption_scenario.rs | 19 +-
.../server/scenarios/log_rotation_scenario.rs | 8 +-
.../server/scenarios/message_cleanup_scenario.rs | 156 +-
.../server/scenarios/purge_delete_scenario.rs | 2 +-
.../scenarios/read_during_persistence_scenario.rs | 2 +-
.../scenarios/reconnect_after_restart_scenario.rs | 17 +-
.../scenarios/restart_offset_skip_scenario.rs | 7 +-
.../scenarios/segment_rotation_race_scenario.rs | 2 +-
.../stale_client_consumer_group_scenario.rs | 262 +-
.../tests/server/scenarios/system_scenario.rs | 39 +-
core/integration/tests/server/specific.rs | 189 +-
core/integration/tests/server/telemetry.rs | 63 +
.../tests/server/topic_admission_vsr.rs | 20 +-
core/journal/Cargo.toml | 7 +-
core/journal/src/durable_storage.rs | 634 +++
core/journal/src/lib.rs | 4 +
core/journal/src/partition_journal.rs | 3675 ++++++++++++
core/journal/src/partition_journal/segments.rs | 858 +++
core/message_bus/src/client_listener/mod.rs | 31 +-
core/message_bus/src/client_listener/tcp_tls.rs | 27 +-
core/message_bus/src/client_listener/wss.rs | 16 +-
core/message_bus/src/config.rs | 14 +-
core/message_bus/src/connector.rs | 38 +-
core/message_bus/src/fd_transfer.rs | 26 +-
core/message_bus/src/framing.rs | 95 +-
core/message_bus/src/installer/common.rs | 7 +-
core/message_bus/src/installer/mod.rs | 56 +-
core/message_bus/src/installer/replica.rs | 26 +-
core/message_bus/src/installer/tcp.rs | 9 +-
core/message_bus/src/installer/tcp_tls.rs | 9 +-
core/message_bus/src/installer/wss.rs | 5 +-
core/message_bus/src/lib.rs | 135 +-
.../src/lifecycle/connection_registry.rs | 11 +-
core/message_bus/src/replica/io.rs | 45 +-
core/message_bus/src/transports/tcp.rs | 296 +-
core/message_bus/src/transports/tcp_tls.rs | 6 +-
core/message_bus/src/transports/wss.rs | 28 +-
core/message_bus/tests/backpressure.rs | 11 +-
core/message_bus/tests/common/mod.rs | 111 +-
core/message_bus/tests/connection_lost_notify.rs | 4 +-
core/message_bus/tests/directional_connection.rs | 13 +-
core/message_bus/tests/head_of_line.rs | 4 +-
core/message_bus/tests/replica_roundtrip.rs | 4 +-
core/message_bus/tests/replica_tls_bench.rs | 4 +-
core/message_bus/tests/replica_tls_mitm.rs | 4 +-
core/message_bus/tests/replica_tls_roundtrip.rs | 8 +-
core/message_bus/tests/shard_zero_gating.rs | 11 +-
core/message_bus/tests/tcp_tls_client_listener.rs | 5 +
core/message_bus/tests/tcp_tls_client_roundtrip.rs | 3 +-
core/message_bus/tests/vectored_batch.rs | 11 +-
core/message_bus/tests/wss_client_listener.rs | 108 +
core/message_bus/tests/wss_client_roundtrip.rs | 3 +-
core/metadata/src/impls/metadata.rs | 459 +-
core/metadata/src/impls/recovery.rs | 53 +-
core/metadata/src/stm/authz.rs | 8 +-
core/metadata/src/stm/consumer_group.rs | 242 +-
core/metadata/src/stm/mod.rs | 24 +-
core/metadata/src/stm/result.rs | 13 +-
core/metadata/src/stm/snapshot.rs | 30 +-
core/metadata/src/stm/stream.rs | 410 +-
core/metadata/src/stm/user.rs | 23 +-
core/partitions/Cargo.toml | 20 +-
core/partitions/src/consumer_offset_capacity.rs | 141 +-
core/partitions/src/iggy_index.rs | 6 +-
core/partitions/src/iggy_index_writer.rs | 27 +-
core/partitions/src/iggy_partition.rs | 5940 ++++++++++++++++++--
core/partitions/src/iggy_partitions.rs | 169 +-
core/partitions/src/install_backup.rs | 234 +
core/partitions/src/journal.rs | 324 +-
core/partitions/src/lib.rs | 22 +-
core/partitions/src/messages_writer.rs | 58 +-
core/{server => partitions}/src/offset_recovery.rs | 201 +-
core/partitions/src/offset_storage.rs | 306 +-
core/partitions/src/partition_storage.rs | 725 +++
core/partitions/src/persistence.rs | 1840 ++++++
core/partitions/src/poll_plan.rs | 1299 ++---
.../{server => partitions}/src/segment_recovery.rs | 1045 +++-
core/partitions/src/state_transfer.rs | 532 +-
core/partitions/src/types.rs | 72 +-
core/partitions/tests/consumer_offset_history.rs | 529 ++
core/sdk/Cargo.toml | 3 +-
core/sdk/README.md | 38 +-
.../src/client_wrappers/binary_message_client.rs | 36 -
core/sdk/src/clients/binary_message.rs | 14 -
core/sdk/src/clients/client.rs | 34 +-
core/sdk/src/clients/consumer.rs | 10 +-
core/sdk/src/clients/producer.rs | 21 +-
core/sdk/src/clients/producer_builder.rs | 4 +-
core/sdk/src/http/messages.rs | 107 +-
core/sdk/src/http/topics.rs | 2 +-
core/sdk/src/leader_aware.rs | 19 +-
core/sdk/src/lib.rs | 1 +
core/sdk/src/poll_routing.rs | 1316 +++++
core/sdk/src/prelude.rs | 8 +-
core/sdk/src/quic/quic_client.rs | 111 +
.../stream_builder/build/build_iggy_consumer.rs | 2 +-
.../stream_builder/config/config_iggy_consumer.rs | 35 +-
.../stream_builder/config/config_iggy_producer.rs | 5 +-
core/sdk/src/tcp/tcp_client.rs | 263 +-
core/sdk/src/vsr.rs | 134 +-
core/sdk/src/websocket/websocket_client.rs | 258 +-
core/server/Cargo.toml | 3 +-
core/server/README.md | 8 +
core/server/config.toml | 416 +-
core/server/src/args.rs | 16 +-
core/server/src/boot/credentials.rs | 6 +-
core/server/src/boot/listeners.rs | 66 +-
core/server/src/boot/mod.rs | 148 +-
core/server/src/boot/recovery.rs | 128 +-
core/server/src/boot/threads.rs | 62 +-
core/server/src/config_writer.rs | 2 +-
core/server/src/consumer_group.rs | 790 ++-
core/server/src/consumer_group/lease.rs | 160 +
core/server/src/consumer_group/liveness.rs | 1034 ++++
core/server/src/dispatch/authz.rs | 104 +-
core/server/src/dispatch/failure.rs | 471 +-
core/server/src/dispatch/host.rs | 213 +
core/server/src/dispatch/mod.rs | 317 +-
core/server/src/dispatch/partition.rs | 1072 ++--
core/server/src/dispatch/reads.rs | 252 +-
core/server/src/dispatch/session_ops.rs | 21 +-
core/server/src/dispatch/submit.rs | 233 +-
core/server/src/dispatch/test_support.rs | 28 +-
core/server/src/http.rs | 19 +-
core/server/src/http/error.rs | 52 +-
core/server/src/http/forward.rs | 446 +-
core/server/src/http/handlers.rs | 60 +-
core/server/src/http/reads.rs | 282 +-
core/server/src/http/reply.rs | 9 +-
core/server/src/http/state.rs | 6 +-
core/server/src/http/submit.rs | 4 +-
core/server/src/http/wire.rs | 2 +-
core/server/src/lib.rs | 14 +-
core/server/src/main.rs | 3 +-
core/server/src/namespace.rs | 362 ++
core/server/src/partition_helpers.rs | 1122 ++--
core/server/src/partition_reconciler.rs | 124 +-
core/server/src/reply_frame.rs | 875 +++
core/server/src/responses.rs | 1416 +----
core/server/src/server_error.rs | 323 +-
core/server/src/session_manager.rs | 192 +-
core/server/src/shard_allocator.rs | 64 +-
core/server/src/shell.rs | 55 +-
core/server/src/snapshot.rs | 28 +-
core/server/src/sysinfo_probe.rs | 151 +
core/server/tests/sdk_e2e.rs | 4 +-
core/server_common/src/consensus_message.rs | 22 +-
core/server_common/src/fs_utils.rs | 46 +
core/server_common/src/iobuf.rs | 4 +
core/server_common/src/lib.rs | 1 +
core/server_common/src/log/logger.rs | 8 +-
core/server_common/src/memory_pool.rs | 4 +-
core/server_common/src/poll.rs | 279 +
.../src/segment_storage/messages_reader.rs | 13 +-
core/server_common/src/segment_storage/mod.rs | 55 +
core/server_common/src/send_messages.rs | 82 +-
core/server_common/src/sharding/mod.rs | 10 +
core/shard/Cargo.toml | 1 +
core/shard/src/builder.rs | 39 +-
core/shard/src/coordinator.rs | 308 +-
core/shard/src/host.rs | 103 +
core/shard/src/lib.rs | 1060 +++-
core/shard/src/metrics.rs | 315 +-
core/shard/src/poll.rs | 366 ++
core/shard/src/poll/completion.rs | 511 ++
core/shard/src/poll/completion_tests.rs | 986 ++++
core/shard/src/poll/test_support.rs | 110 +
core/shard/src/poll/timeout_tests.rs | 532 ++
core/shard/src/router.rs | 162 +-
core/simulator/Cargo.toml | 1 +
core/simulator/README.md | 1 +
core/simulator/src/bin/simulator-ui.rs | 21 +-
core/simulator/src/bin/workload-fuzz.rs | 137 +-
core/simulator/src/bus.rs | 44 +-
core/simulator/src/client.rs | 18 +-
.../simulator/src/consumer_offset_history_tests.rs | 220 +
core/simulator/src/lib.rs | 1033 +++-
core/simulator/src/packet.rs | 7 +-
core/simulator/src/replica.rs | 63 +-
core/simulator/src/storage.rs | 677 +++
core/simulator/src/storage/purge.rs | 474 ++
core/simulator/src/storage/tests.rs | 3070 ++++++++++
core/simulator/src/workload/invariants.rs | 30 +
core/simulator/src/workload/mod.rs | 18 +-
core/simulator/src/workload/oracle.rs | 27 +-
core/simulator/src/workload/state_checker.rs | 66 +-
examples/csharp/README.md | 31 +-
.../Iggy_SDK.Examples.Basic.Consumer.csproj | 8 +-
.../Iggy_SDK.Examples.Basic.Producer.csproj | 10 +-
...ggy_SDK.Examples.GettingStarted.Consumer.csproj | 4 +-
.../Utils.cs | 7 +-
...ggy_SDK.Examples.GettingStarted.Producer.csproj | 4 +-
.../Utils.cs | 32 +-
.../src/Iggy_SDK.Examples.Shared/ExampleHelpers.cs | 29 +-
.../Iggy_SDK.Examples.Shared.csproj | 2 +-
...gy_SDK.Examples.MessageEnvelope.Consumer.csproj | 10 +-
.../Utils.cs | 7 +-
...gy_SDK.Examples.MessageEnvelope.Producer.csproj | 10 +-
.../Utils.cs | 29 +-
...ggy_SDK.Examples.MessageHeaders.Consumer.csproj | 4 +-
.../Utils.cs | 7 +-
...ggy_SDK.Examples.MessageHeaders.Producer.csproj | 4 +-
.../Utils.cs | 29 +-
.../Iggy_SDK.Examples.NewSdk.Consumer.csproj | 10 +-
.../Iggy_SDK.Examples.NewSdk.Producer.csproj | 10 +-
.../Iggy_SDK.Examples.TcpTls.Consumer.csproj | 4 +-
.../Iggy_SDK.Examples.TcpTls.Consumer/Program.cs | 2 +-
.../Iggy_SDK.Examples.TcpTls.Producer.csproj | 4 +-
examples/go/README.md | 31 +-
examples/go/getting-started/consumer/main.go | 2 +-
examples/go/getting-started/consumer/main_test.go | 89 +
examples/go/go.mod | 2 +-
examples/go/go.sum | 4 +-
examples/java/README.md | 34 +-
examples/java/build.gradle.kts | 10 +-
examples/java/settings.gradle.kts | 8 +
.../apache/iggy/examples/async/AsyncConsumer.java | 14 +-
.../consumer/GettingStartedConsumer.java | 5 +-
.../consumer/MessageEnvelopeConsumer.java | 5 +-
.../consumer/MessageHeadersConsumer.java | 3 +-
.../multitenant/consumer/MultiTenantConsumer.java | 3 +-
.../multitenant/producer/MultiTenantProducer.java | 3 +-
.../iggy/examples/streambuilder/StreamBasic.java | 3 +-
.../examples/tcptls/consumer/TcpTlsConsumer.java | 11 +-
.../examples/tcptls/producer/TcpTlsProducer.java | 6 +-
.../apache/iggy/examples/ConsumerOffsetTest.java | 213 +
.../iggy/examples/MultiTenantAccessTest.java | 141 +
examples/node/README.md | 58 +-
examples/node/package-lock.json | 186 +-
examples/node/package.json | 7 +-
examples/node/src/basic/consumer.ts | 11 +-
examples/node/src/getting-started/consumer.ts | 7 +-
examples/node/src/message-envelope/consumer.ts | 9 +-
examples/node/src/message-headers/consumer.ts | 9 +-
examples/node/src/multi-tenant/consumer.ts | 9 +-
examples/node/src/sink-data-producer/producer.ts | 2 +-
examples/node/src/tcp-tls/consumer.ts | 13 +-
examples/node/src/tcp-tls/producer.ts | 9 +-
examples/node/tests/consumer-offset.test.mjs | 106 +
examples/php/README.md | 7 +-
examples/php/src/common.php | 18 +-
examples/python/README.md | 80 +-
examples/python/high-level/background_producer.py | 108 +
examples/python/high-level/consumer.py | 93 +
examples/python/high-level/producer.py | 122 +
examples/python/pyproject.toml | 4 +-
examples/python/uv.lock | 70 +-
examples/rust/README.md | 30 +-
examples/rust/src/basic/consumer/main.rs | 3 +
examples/rust/src/basic/producer/main.rs | 3 +
.../stream-builder/stream-consumer-config/main.rs | 18 +-
.../stream-builder/stream-producer-config/main.rs | 10 +-
examples/rust/src/tcp-tls/consumer/main.rs | 4 +-
examples/rust/src/tcp-tls/producer/main.rs | 4 +-
foreign/cpp/.clang-tidy | 49 +
foreign/cpp/BUILD.bazel | 1 +
foreign/cpp/Cargo.toml | 2 +-
foreign/cpp/MODULE.bazel | 5 +-
foreign/cpp/MODULE.bazel.lock | 7 +-
foreign/cpp/README.md | 8 +-
foreign/cpp/include/iggy.hpp | 3781 ++++++++++++-
foreign/cpp/src/client.cpp | 366 +-
foreign/cpp/src/client.rs | 175 +-
foreign/cpp/src/lib.rs | 74 +-
foreign/cpp/src/type_conversion.rs | 177 +-
foreign/cpp/src/type_conversions.cpp | 357 ++
foreign/cpp/tests/e2e/client.cpp | 2844 ++++------
foreign/cpp/tests/e2e/consumer_group.cpp | 2325 +++++---
foreign/cpp/tests/e2e/message.cpp | 156 +-
foreign/cpp/tests/e2e/partition.cpp | 438 +-
foreign/cpp/tests/e2e/stream.cpp | 1061 ++--
foreign/cpp/tests/e2e/test_helpers.hpp | 44 +-
foreign/cpp/tests/e2e/topic.cpp | 1804 +++---
foreign/cpp/tests/unit/unit_tests.cpp | 400 +-
foreign/csharp/Directory.Packages.props | 18 +-
.../Fixtures/VsrCluster.cs | 4 +-
.../FlushMessagesTests.cs | 40 -
.../Iggy_SDK.Tests.Integration/OptionsTests.cs | 21 +-
foreign/csharp/Iggy_SDK/Consumers/IggyConsumer.cs | 21 +-
.../Iggy_SDK/Consumers/IggyConsumerBuilder.cs | 4 +-
.../Iggy_SDK/Consumers/IggyConsumerConfig.cs | 4 +-
.../Iggy_SDK/Contracts/Auth/GlobalPermissions.cs | 3 -
.../Iggy_SDK/Contracts/SendMessagesResponse.cs | 4 +-
.../csharp/Iggy_SDK/Contracts/StreamPermissions.cs | 3 -
foreign/csharp/Iggy_SDK/Contracts/TopicOptions.cs | 52 +-
.../csharp/Iggy_SDK/Contracts/TopicPermissions.cs | 3 -
.../Iggy_SDK/Enums/{Protocol.cs => Durability.cs} | 19 +-
.../csharp/Iggy_SDK/IggyClient/IIggyPublisher.cs | 17 -
foreign/csharp/Iggy_SDK/IggyClient/IIggySegment.cs | 6 +-
foreign/csharp/Iggy_SDK/IggyClient/IIggyTopic.cs | 4 +-
.../Implementations/HttpMessageStream.cs | 32 +-
.../TcpMessageStream.PollRouting.cs | 463 ++
.../Implementations/TcpMessageStream.Vsr.cs | 13 +-
.../IggyClient/Implementations/TcpMessageStream.cs | 38 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 8 +-
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 2 +-
.../csharp/Iggy_SDK/Publishers/IggyPublisher.cs | 41 +-
.../Iggy_SDK/Publishers/IggyPublisherBuilder.cs | 12 +-
.../Iggy_SDK/Publishers/IggyPublisherConfig.cs | 10 +-
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 5 +-
.../Iggy_SDK/Vsr/ConsumerGroupClientState.cs | 4 +-
foreign/csharp/Iggy_SDK/Vsr/VsrConnection.cs | 28 +-
foreign/csharp/Iggy_SDK/Vsr/VsrHeader.cs | 1 +
foreign/csharp/Iggy_SDK/Vsr/VsrOperation.cs | 9 +-
.../ClientTests/ExampleHelpersTests.cs | 80 +
.../ClientTests/HttpTopicOptionsTests.cs | 74 +-
.../ConsumerTests/IggyConsumerBuilderTests.cs | 38 +
.../csharp/Iggy_SDK_Tests/Iggy_SDK_Tests.csproj | 1 +
.../Iggy_SDK_Tests/MapperTests/BinaryMapper.cs | 4 +-
.../MapperTests/OptionsBlockGoldenVectorTests.cs | 26 +-
.../MapperTests/ResourceOptionsConverterTests.cs | 8 +-
.../PublisherTests/IggyTypedPublisherTests.cs | 83 +
.../UtilityTests/TopicOptionsTests.cs | 20 +-
foreign/csharp/Iggy_SDK_Tests/VsrTests/MockNode.cs | 14 +-
.../Iggy_SDK_Tests/VsrTests/PrimaryPollingTests.cs | 635 +++
.../VsrTests/VsrProtocolDriftTests.cs | 1 +
foreign/csharp/README.md | 299 +-
foreign/csharp/README.nuget.md | 19 +
foreign/go/README.md | 63 +-
.../binary_response_deserializer.go | 4 +-
foreign/go/client/tcp/cluster.go | 7 +
foreign/go/client/tcp/tcp_core.go | 80 +-
foreign/go/client/tcp/tcp_group_polling.go | 4 +-
foreign/go/client/tcp/tcp_messaging.go | 22 +-
foreign/go/client/tcp/tcp_offset_management.go | 9 +
foreign/go/client/tcp/tcp_poll_routing.go | 435 ++
foreign/go/client/tcp/tcp_poll_routing_test.go | 815 +++
foreign/go/client/tcp/tcp_session_management.go | 4 +
foreign/go/client/tcp/tcp_testing_test.go | 6 +-
foreign/go/client/tcp/tcp_user_management.go | 40 +
foreign/go/contracts/client.go | 19 +-
foreign/go/contracts/compression_algorithm_test.go | 14 +-
foreign/go/contracts/topic_options.go | 19 +-
foreign/go/contracts/topic_options_test.go | 24 +-
foreign/go/contracts/version.go | 2 +-
foreign/go/go.mod | 2 +-
foreign/go/go.sum | 4 +-
foreign/go/internal/command/code.go | 104 +-
foreign/go/internal/command/session_test.go | 33 +
foreign/go/internal/command/system_test.go | 105 +
foreign/go/internal/command/topic.go | 20 +-
foreign/go/internal/command/topic_test.go | 20 +-
foreign/go/internal/command/user_test.go | 75 +
foreign/go/internal/vsr/header.go | 14 +
foreign/go/internal/vsr/header_test.go | 31 +
foreign/go/internal/vsr/protocol_parity_test.go | 8 +-
foreign/go/tests/e2e_helpers_test.go | 2 +-
foreign/go/tests/e2e_test.go | 155 +-
foreign/java/README.md | 45 +-
.../iggy-connector-flink/docker-compose.yml | 2 +-
.../iggy-connector-pinot/docker-compose.yml | 2 +-
.../connector/pinot/IggyPinotIntegrationTest.java | 2 +-
foreign/java/gradle.properties | 2 +-
foreign/java/gradle/libs.versions.toml | 6 +-
.../apache/iggy/client/async/MessagesClient.java | 13 +-
.../iggy/client/async/tcp/AsyncIggyTcpClient.java | 130 +-
.../iggy/client/async/tcp/AsyncTcpConnection.java | 136 +-
.../iggy/client/async/tcp/LoginRoutingHook.java | 3 +
.../iggy/client/async/tcp/MessagesTcpClient.java | 168 +-
.../apache/iggy/client/async/tcp/PollRouter.java | 499 ++
.../iggy/client/async/tcp/TopicsTcpClient.java | 8 +-
.../iggy/client/async/tcp/UsersTcpClient.java | 15 +-
.../client/async/tcp/vsr/ConsensusSession.java | 18 +
.../iggy/client/async/tcp/vsr/VsrHeaders.java | 1 +
.../client/async/tcp/vsr/VsrResponseHandler.java | 6 +
.../client/blocking/http/TopicsHttpClient.java | 2 +-
.../org/apache/iggy/serde/BytesSerializer.java | 194 +-
.../java/org/apache/iggy/serde/CommandCode.java | 5 +-
.../java/org/apache/iggy/topic/Durability.java} | 15 +-
.../java/org/apache/iggy/topic/TopicOptions.java | 37 +-
.../apache/iggy/client/BaseIntegrationTest.java | 2 +-
.../AsyncIggyTcpClientTransientFailoverTest.java | 1026 +++-
.../tcp/AsyncTcpConnectionConcurrencyTest.java | 55 +
.../async/tcp/vsr/VsrResponseHandlerTest.java | 18 +
.../iggy/client/blocking/SystemClientBaseTest.java | 2 +-
.../iggy/client/blocking/TopicsClientBaseTest.java | 12 +-
.../client/blocking/tcp/TopicsTcpClientTest.java | 4 +-
.../iggy/serde/MessagesBatchWireFormatTest.java | 123 +-
.../iggy/serde/OptionsBlockGoldenVectorTest.java | 16 +-
.../org/apache/iggy/topic/TopicOptionsTest.java | 20 +-
foreign/node/README.md | 27 +-
foreign/node/package-lock.json | 494 +-
foreign/node/package.json | 6 +-
foreign/node/src/client/client.connection.ts | 4 +-
foreign/node/src/client/client.socket.test.ts | 641 +++
foreign/node/src/client/client.socket.ts | 302 +-
foreign/node/src/wire/command-set.ts | 4 +-
foreign/node/src/wire/command.code.ts | 5 +-
.../wire/message/flush-unsaved-buffers.command.ts | 53 -
foreign/node/src/wire/message/message.utils.ts | 30 +-
.../src/wire/message/poll-messages.command.test.ts | 14 +
.../node/src/wire/message/poll-messages.command.ts | 5 +-
.../node/src/wire/message/send-messages.command.ts | 5 +-
foreign/node/src/wire/options.utils.test.ts | 15 +-
foreign/node/src/wire/token/token.utils.test.ts | 88 +
foreign/node/src/wire/token/token.utils.ts | 10 +-
.../src/wire/topic/create-topic.command.test.ts | 42 +-
.../node/src/wire/topic/create-topic.command.ts | 27 +-
foreign/node/src/wire/topic/index.ts | 2 +-
foreign/node/src/wire/topic/topic.utils.ts | 7 +
foreign/node/src/wire/vsr/header.ts | 1 +
foreign/node/src/wire/vsr/index.ts | 2 +-
foreign/php/Cargo.toml | 2 +-
foreign/php/README.md | 44 +-
foreign/php/iggy-php.stubs.php | 15 +-
foreign/php/src/client.rs | 9 +-
.../Auth/AuthResponse.cs => php/src/durability.rs} | 27 +-
foreign/php/src/lib.rs | 2 +
foreign/php/src/send_message.rs | 5 +-
foreign/php/tests/IggySdkTest.php | 62 +
foreign/python/Cargo.toml | 4 +-
foreign/python/README.md | 158 +-
foreign/python/apache_iggy.pyi | 321 +-
foreign/python/pyproject.toml | 2 +-
foreign/python/src/bin/stub_gen.rs | 8 +-
foreign/python/src/client.rs | 201 +-
foreign/python/src/durability.rs | 58 +
foreign/python/src/lib.rs | 15 +-
foreign/python/src/partitioning.rs | 27 +-
foreign/python/src/producer.rs | 1307 +++++
foreign/python/src/send_message.rs | 44 +-
foreign/python/tests/test_connectivity.py | 183 +-
foreign/python/tests/test_producer.py | 1608 ++++++
foreign/python/tests/test_topic.py | 21 +-
foreign/python/tests/test_user.py | 36 +
foreign/python/uv.lock | 66 +-
foreign/swift/.swift-format | 22 +
.../consts.go => foreign/swift/Package.swift | 27 +-
foreign/swift/README.md | 98 +
foreign/swift/Sources/Iggy/Errors/IggyError.swift | 78 +
.../swift/Sources/Iggy/Errors/IggyErrorCode.swift | 515 ++
.../swift/Sources/Iggy/Hash/UnalignedLoads.swift | 18 +-
foreign/swift/Sources/Iggy/Hash/XXH3.swift | 273 +
foreign/swift/Sources/Iggy/Hash/XXH32.swift | 79 +
.../swift/Sources/Iggy/Iggy.swift | 20 +-
foreign/swift/Sources/Iggy/Models/Identifier.swift | 118 +
.../swift/Sources/Iggy/Models/IggyMessage.swift | 223 +
foreign/swift/Sources/Iggy/Models/Messaging.swift | 241 +
.../swift/Sources/Iggy/Models/Permissions.swift | 186 +
.../Sources/Iggy/Models/ResourceOptions.swift | 168 +
foreign/swift/Sources/Iggy/Models/Resources.swift | 628 +++
.../swift/Sources/Iggy/Models/TopicOptions.swift | 206 +
.../swift/Sources/Iggy/Models/UserHeaders.swift | 427 ++
.../Sources/Iggy/Utilities/UInt128Value.swift | 156 +
foreign/swift/Sources/Iggy/Wire/ByteCodec.swift | 225 +
foreign/swift/Tests/IggyTests/ByteCodecTests.swift | 120 +
foreign/swift/Tests/IggyTests/ErrorCodeTests.swift | 63 +
foreign/swift/Tests/IggyTests/Fixtures/golden.json | 1006 ++++
foreign/swift/Tests/IggyTests/HashTests.swift | 62 +
foreign/swift/Tests/IggyTests/ModelTests.swift | 379 ++
.../swift/Tests/IggyTests/ModelVectorTests.swift | 116 +
.../Tests/IggyTests/Support/GoldenFixture.swift | 105 +
.../swift/Tools/golden-vectors}/Cargo.toml | 22 +-
foreign/swift/Tools/golden-vectors/src/main.rs | 1440 +++++
gateways/kafka/Cargo.toml | 33 +-
gateways/kafka/README.md | 315 +-
gateways/kafka/docs/ACL_MAPPING.md | 195 +
gateways/kafka/docs/AUTHENTICATION.md | 260 +
gateways/kafka/docs/BRIDGE_MAPPING.md | 428 ++
gateways/kafka/docs/CONSUMER_GROUPS.md | 191 +
gateways/kafka/docs/IDEMPOTENCE.md | 254 +
gateways/kafka/docs/MANUAL_TESTING.md | 198 +-
gateways/kafka/docs/OFFSET_STORAGE.md | 202 +
gateways/kafka/docs/SCOPE.md | 296 +-
gateways/kafka/docs/TEST_SUITE.md | 52 +-
gateways/kafka/docs/kafka_api_keys_reference.md | 53 +-
gateways/kafka/scripts/ci-wire-fixtures.sh | 2 +-
gateways/kafka/src/auth.rs | 805 +++
gateways/kafka/src/bridge/config.rs | 430 ++
gateways/kafka/src/bridge/error.rs | 472 ++
.../kafka/src/bridge/iggy_bridge/fetch.rs | 11 +-
gateways/kafka/src/bridge/iggy_bridge/mod.rs | 180 +
gateways/kafka/src/bridge/iggy_bridge/offsets.rs | 171 +
gateways/kafka/src/bridge/iggy_bridge/produce.rs | 200 +
gateways/kafka/src/bridge/iggy_bridge/topics.rs | 496 ++
.../jwks.rs => gateways/kafka/src/bridge/mod.rs | 22 +-
gateways/kafka/src/bridge/topic_map.rs | 572 ++
gateways/kafka/src/env.rs | 64 +
gateways/kafka/src/group/mod.rs | 632 +++
gateways/kafka/src/group/state.rs | 2956 ++++++++++
gateways/kafka/src/lib.rs | 5 +
gateways/kafka/src/main.rs | 292 +-
gateways/kafka/src/protocol/acl.rs | 600 ++
gateways/kafka/src/protocol/api.rs | 910 ++-
gateways/kafka/src/protocol/bounds_guard.rs | 722 ++-
.../kafka/src/protocol/handlers/api_versions.rs | 125 +
.../kafka/src/protocol/handlers/create_topics.rs | 797 +++
gateways/kafka/src/protocol/handlers/fetch.rs | 118 +
.../src/protocol/handlers/find_coordinator.rs | 169 +
gateways/kafka/src/protocol/handlers/heartbeat.rs | 78 +
.../src/protocol/handlers/init_producer_id.rs | 207 +
gateways/kafka/src/protocol/handlers/join_group.rs | 158 +
.../kafka/src/protocol/handlers/leave_group.rs | 211 +
.../kafka/src/protocol/handlers/list_offsets.rs | 523 ++
gateways/kafka/src/protocol/handlers/metadata.rs | 683 +++
gateways/kafka/src/protocol/handlers/mod.rs | 203 +
gateways/kafka/src/protocol/handlers/produce.rs | 992 ++++
gateways/kafka/src/protocol/handlers/sync_group.rs | 89 +
gateways/kafka/src/protocol/mod.rs | 4 +-
gateways/kafka/src/protocol/responses.rs | 318 --
gateways/kafka/src/protocol/sasl.rs | 573 ++
gateways/kafka/src/records.rs | 2296 ++++++++
gateways/kafka/src/server.rs | 749 ++-
gateways/kafka/tests/api_handler_tests.rs | 228 +-
.../kafka/tests/bridge_iggy_integration_tests.rs | 909 +++
gateways/kafka/tests/broker_advertise_tests.rs | 5 +-
gateways/kafka/tests/common/codec.rs | 11 +
gateways/kafka/tests/common/iggy_server.rs | 407 ++
gateways/kafka/tests/common/scope.rs | 12 +-
gateways/kafka/tests/common/server.rs | 28 +-
gateways/kafka/tests/common/wire.rs | 251 +-
gateways/kafka/tests/consumer_group_tests.rs | 1641 ++++++
.../kafka/tests/create_topics_real_bridge_tests.rs | 540 ++
gateways/kafka/tests/golden_wire_fixtures_tests.rs | 76 +-
gateways/kafka/tests/idempotence_tests.rs | 439 ++
gateways/kafka/tests/kafka_client_e2e_tests.rs | 725 +++
.../kafka/tests/list_offsets_real_bridge_tests.rs | 406 ++
gateways/kafka/tests/listener_robustness_tests.rs | 61 +-
gateways/kafka/tests/metadata_real_bridge_tests.rs | 428 ++
gateways/kafka/tests/produce_real_bridge_tests.rs | 754 +++
gateways/kafka/tests/response_negative_tests.rs | 51 +-
gateways/kafka/tests/sasl_tests.rs | 1709 ++++++
gateways/kafka/tests/server_e2e_tests.rs | 32 +-
gateways/kafka/tests/version_firewall_tests.rs | 215 +-
gateways/kafka/tools/kafka-tool/README.md | 10 +-
gateways/kafka/tools/kafka-tool/src/main.rs | 67 +-
gateways/kafka/tools/kafka-tool/src/response.rs | 18 +-
helm/charts/iggy/README.md | 13 +-
helm/charts/iggy/README.md.gotmpl | 8 +-
helm/charts/iggy/templates/_helpers.tpl | 19 +-
helm/charts/iggy/values.yaml | 4 +
licenserc.toml | 8 +
scripts/bump-version.sh | 4 +-
scripts/ci/license-headers.sh | 6 +-
scripts/ci/test-helm.sh | 47 +-
.../performance/run-standard-performance-suite.sh | 53 +-
scripts/performance/utils.sh | 9 +-
scripts/prepare-release.sh | 2 +
scripts/utils.sh | 40 +-
web/README.md | 22 +-
web/package-lock.json | 603 +-
web/package.json | 29 +-
web/src/lib/api/ApiSchema.ts | 7 +-
web/src/lib/components/Breadcrumbs.svelte | 5 +-
.../components/Modals/DeletePartitionsModal.svelte | 2 +-
.../components/Modals/StreamSettingsModal.svelte | 2 +-
.../components/Modals/TopicSettingsModal.svelte | 7 +-
.../src/lib/utils/base64Utils.test.mjs | 27 +-
web/src/lib/utils/base64Utils.ts | 3 +-
.../topics/[topicId=i32]/+page.svelte | 2 +-
968 files changed, 134153 insertions(+), 22214 deletions(-)
create mode 100644 .github/actions/swift/pre-merge/action.yml
create mode 100644 .github/actions/utils/setup-swift/action.yml
create mode 100644 .github/review-bot/README.md
create mode 100644 .github/review-bot/comment-style.md
create mode 100644 .github/review-bot/prompt.md
create mode 100644 .github/workflows/codecov-notify.yml
create mode 100644 .github/workflows/pr-skill-review-post.yml
create mode 100644 .github/workflows/pr-skill-review-run.yml
create mode 100644 core/binary_protocol/src/consensus/consumer_session.rs
create mode 100644 core/binary_protocol/src/consensus/request.rs
delete mode 100644
core/binary_protocol/src/requests/messages/flush_unsaved_buffer.rs
create mode 100644
core/binary_protocol/src/requests/system/attach_consumer_session.rs
create mode 100644 core/binary_protocol/src/responses/messages/poll_routing.rs
delete mode 100644 core/cli/src/commands/binary_message/flush_messages.rs
delete mode 100644 core/common/src/http/messages/flush_unsaved_buffer.rs
copy core/common/src/types/{cluster/role.rs => options/durability.rs} (53%)
create mode 100644
core/connectors/runtime/example_config/connectors/http_source_github.toml
create mode 100644
core/connectors/runtime/example_config/connectors/http_source_partner.toml
copy core/connectors/{sinks/delta_sink => sources/http_source}/Cargo.toml (79%)
create mode 100644 core/connectors/sources/http_source/README.md
create mode 100644 core/connectors/sources/http_source/config.toml
create mode 100644 core/connectors/sources/http_source/src/auth.rs
create mode 100644 core/connectors/sources/http_source/src/lib.rs
create mode 100644 core/connectors/sources/http_source/src/management.rs
create mode 100644 core/connectors/sources/http_source/src/metrics.rs
create mode 100644 core/connectors/sources/http_source/src/routes.rs
create mode 100644 core/connectors/sources/http_source/src/server.rs
create mode 100644 core/connectors/sources/http_source/src/state.rs
create mode 100644 core/connectors/sources/http_source/src/types.rs
create mode 100644 core/integration/tests/bench.rs
delete mode 100644
core/integration/tests/cli/message/test_message_flush_command.rs
create mode 100644 core/integration/tests/cluster/replica_read_batching.rs
create mode 100644 core/integration/tests/connectors/clickhouse/proto_text.rs
copy core/integration/tests/connectors/{delta/sink.toml =>
clickhouse/proto_text.toml} (93%)
copy core/{connectors/runtime/example_config/connectors =>
integration/tests/connectors/clickhouse/proto_text_config}/clickhouse_sink.toml
(54%)
copy core/{connectors/sinks/stdout_sink =>
integration/tests/connectors/delta/malformed_table_uri_config}/config.toml (74%)
copy core/integration/tests/connectors/delta/{sink.toml =>
malformed_table_uri_sink.toml} (92%)
copy
core/integration/tests/connectors/{runtime/sink_invalid_config/stdout_valid.toml
=> delta/missing_secret_key_config/config.toml} (67%)
copy core/integration/tests/connectors/delta/{sink.toml =>
missing_secret_key_sink.toml} (92%)
copy core/integration/tests/connectors/{meilisearch/meilisearch_sink.rs =>
doris/proto_text.rs} (55%)
copy core/integration/tests/connectors/{delta/sink.toml =>
doris/proto_text.toml} (93%)
create mode 100644
core/integration/tests/connectors/doris/proto_text_config/doris_sink.toml
create mode 100644
core/integration/tests/connectors/elasticsearch/proto_text.rs
copy core/integration/tests/connectors/{delta/sink.toml =>
elasticsearch/proto_text.toml} (92%)
copy core/{connectors/sinks/elasticsearch_sink/config.toml =>
integration/tests/connectors/elasticsearch/proto_text_config/elasticsearch_sink.toml}
(57%)
create mode 100644 core/integration/tests/connectors/fixtures/floci.rs
create mode 100644 core/integration/tests/connectors/fixtures/http/source.rs
create mode 100644 core/integration/tests/connectors/http/http_source.rs
copy core/integration/tests/connectors/{random => http}/source.toml (94%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/http/source_config/http_github.toml} (53%)
copy core/{connectors/sources/random_source/config.toml =>
integration/tests/connectors/http/source_config/http_partner.toml} (59%)
create mode 100644 core/integration/tests/connectors/runtime/schema_tagging.rs
copy core/integration/tests/connectors/{delta/sink.toml =>
runtime/schema_tagging.toml} (92%)
copy
core/integration/tests/connectors/runtime/{sink_invalid_config/stdout_valid.toml
=> schema_tagging_config/stdout_sink.toml} (76%)
copy core/integration/tests/connectors/runtime/{source_invalid_state.toml =>
sink_transform_error.toml} (92%)
copy
core/integration/tests/connectors/runtime/{sink_invalid_config/stdout_valid.toml
=> sink_transform_error_config/stdout.toml} (72%)
delete mode 100644 core/integration/tests/server/flush_vsr.rs
create mode 100644 core/integration/tests/server/telemetry.rs
create mode 100644 core/journal/src/durable_storage.rs
create mode 100644 core/journal/src/partition_journal.rs
create mode 100644 core/journal/src/partition_journal/segments.rs
create mode 100644 core/partitions/src/install_backup.rs
rename core/{server => partitions}/src/offset_recovery.rs (60%)
create mode 100644 core/partitions/src/partition_storage.rs
create mode 100644 core/partitions/src/persistence.rs
rename core/{server => partitions}/src/segment_recovery.rs (85%)
create mode 100644 core/partitions/tests/consumer_offset_history.rs
create mode 100644 core/sdk/src/poll_routing.rs
create mode 100644 core/server/src/consumer_group/lease.rs
create mode 100644 core/server/src/consumer_group/liveness.rs
create mode 100644 core/server/src/dispatch/host.rs
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 core/server_common/src/poll.rs
create mode 100644 core/shard/src/host.rs
create mode 100644 core/shard/src/poll.rs
create mode 100644 core/shard/src/poll/completion.rs
create mode 100644 core/shard/src/poll/completion_tests.rs
create mode 100644 core/shard/src/poll/test_support.rs
create mode 100644 core/shard/src/poll/timeout_tests.rs
create mode 100644 core/simulator/src/consumer_offset_history_tests.rs
create mode 100644 core/simulator/src/storage.rs
create mode 100644 core/simulator/src/storage/purge.rs
create mode 100644 core/simulator/src/storage/tests.rs
create mode 100644 examples/go/getting-started/consumer/main_test.go
create mode 100644
examples/java/src/test/java/org/apache/iggy/examples/ConsumerOffsetTest.java
create mode 100644
examples/java/src/test/java/org/apache/iggy/examples/MultiTenantAccessTest.java
create mode 100644 examples/node/tests/consumer-offset.test.mjs
create mode 100644 examples/python/high-level/background_producer.py
create mode 100644 examples/python/high-level/consumer.py
create mode 100644 examples/python/high-level/producer.py
create mode 100644 foreign/cpp/.clang-tidy
create mode 100644 foreign/cpp/src/type_conversions.cpp
delete mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/FlushMessagesTests.cs
copy foreign/csharp/Iggy_SDK/Enums/{Protocol.cs => Durability.cs} (72%)
create mode 100644
foreign/csharp/Iggy_SDK/IggyClient/Implementations/TcpMessageStream.PollRouting.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/ClientTests/ExampleHelpersTests.cs
create mode 100644
foreign/csharp/Iggy_SDK_Tests/VsrTests/PrimaryPollingTests.cs
create mode 100644 foreign/csharp/README.nuget.md
create mode 100644 foreign/go/client/tcp/tcp_poll_routing.go
create mode 100644 foreign/go/client/tcp/tcp_poll_routing_test.go
create mode 100644 foreign/go/internal/command/system_test.go
create mode 100644
foreign/java/java-sdk/src/main/java/org/apache/iggy/client/async/tcp/PollRouter.java
copy
foreign/java/{bench/src/main/java/org/apache/iggy/bench/common/enums/TransportKind.java
=> java-sdk/src/main/java/org/apache/iggy/topic/Durability.java} (81%)
delete mode 100644
foreign/node/src/wire/message/flush-unsaved-buffers.command.ts
create mode 100644 foreign/node/src/wire/token/token.utils.test.ts
copy foreign/{csharp/Iggy_SDK/Contracts/Auth/AuthResponse.cs =>
php/src/durability.rs} (64%)
create mode 100644 foreign/python/src/durability.rs
create mode 100644 foreign/python/src/producer.rs
create mode 100644 foreign/python/tests/test_producer.py
create mode 100644 foreign/swift/.swift-format
copy examples/go/common/consts.go => foreign/swift/Package.swift (60%)
create mode 100644 foreign/swift/README.md
create mode 100644 foreign/swift/Sources/Iggy/Errors/IggyError.swift
create mode 100644 foreign/swift/Sources/Iggy/Errors/IggyErrorCode.swift
copy core/connectors/sdk/src/decoders/raw.rs =>
foreign/swift/Sources/Iggy/Hash/UnalignedLoads.swift (62%)
create mode 100644 foreign/swift/Sources/Iggy/Hash/XXH3.swift
create mode 100644 foreign/swift/Sources/Iggy/Hash/XXH32.swift
copy bdd/rust/tests/leader_redirection.rs =>
foreign/swift/Sources/Iggy/Iggy.swift (67%)
create mode 100644 foreign/swift/Sources/Iggy/Models/Identifier.swift
create mode 100644 foreign/swift/Sources/Iggy/Models/IggyMessage.swift
create mode 100644 foreign/swift/Sources/Iggy/Models/Messaging.swift
create mode 100644 foreign/swift/Sources/Iggy/Models/Permissions.swift
create mode 100644 foreign/swift/Sources/Iggy/Models/ResourceOptions.swift
create mode 100644 foreign/swift/Sources/Iggy/Models/Resources.swift
create mode 100644 foreign/swift/Sources/Iggy/Models/TopicOptions.swift
create mode 100644 foreign/swift/Sources/Iggy/Models/UserHeaders.swift
create mode 100644 foreign/swift/Sources/Iggy/Utilities/UInt128Value.swift
create mode 100644 foreign/swift/Sources/Iggy/Wire/ByteCodec.swift
create mode 100644 foreign/swift/Tests/IggyTests/ByteCodecTests.swift
create mode 100644 foreign/swift/Tests/IggyTests/ErrorCodeTests.swift
create mode 100644 foreign/swift/Tests/IggyTests/Fixtures/golden.json
create mode 100644 foreign/swift/Tests/IggyTests/HashTests.swift
create mode 100644 foreign/swift/Tests/IggyTests/ModelTests.swift
create mode 100644 foreign/swift/Tests/IggyTests/ModelVectorTests.swift
create mode 100644 foreign/swift/Tests/IggyTests/Support/GoldenFixture.swift
copy {core/bench/dashboard/shared =>
foreign/swift/Tools/golden-vectors}/Cargo.toml (62%)
create mode 100644 foreign/swift/Tools/golden-vectors/src/main.rs
create mode 100644 gateways/kafka/docs/ACL_MAPPING.md
create mode 100644 gateways/kafka/docs/AUTHENTICATION.md
create mode 100644 gateways/kafka/docs/BRIDGE_MAPPING.md
create mode 100644 gateways/kafka/docs/CONSUMER_GROUPS.md
create mode 100644 gateways/kafka/docs/IDEMPOTENCE.md
create mode 100644 gateways/kafka/docs/OFFSET_STORAGE.md
create mode 100644 gateways/kafka/src/auth.rs
create mode 100644 gateways/kafka/src/bridge/config.rs
create mode 100644 gateways/kafka/src/bridge/error.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
create mode 100644 gateways/kafka/src/bridge/iggy_bridge/produce.rs
create mode 100644 gateways/kafka/src/bridge/iggy_bridge/topics.rs
copy core/integration/src/harness/config/jwks.rs =>
gateways/kafka/src/bridge/mod.rs (59%)
create mode 100644 gateways/kafka/src/bridge/topic_map.rs
create mode 100644 gateways/kafka/src/env.rs
create mode 100644 gateways/kafka/src/group/mod.rs
create mode 100644 gateways/kafka/src/group/state.rs
create mode 100644 gateways/kafka/src/protocol/acl.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/find_coordinator.rs
create mode 100644 gateways/kafka/src/protocol/handlers/heartbeat.rs
create mode 100644 gateways/kafka/src/protocol/handlers/init_producer_id.rs
create mode 100644 gateways/kafka/src/protocol/handlers/join_group.rs
create mode 100644 gateways/kafka/src/protocol/handlers/leave_group.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
create mode 100644 gateways/kafka/src/protocol/handlers/sync_group.rs
delete mode 100644 gateways/kafka/src/protocol/responses.rs
create mode 100644 gateways/kafka/src/protocol/sasl.rs
create mode 100644 gateways/kafka/src/records.rs
create mode 100644 gateways/kafka/tests/bridge_iggy_integration_tests.rs
create mode 100644 gateways/kafka/tests/common/iggy_server.rs
create mode 100644 gateways/kafka/tests/consumer_group_tests.rs
create mode 100644 gateways/kafka/tests/create_topics_real_bridge_tests.rs
create mode 100644 gateways/kafka/tests/idempotence_tests.rs
create mode 100644 gateways/kafka/tests/kafka_client_e2e_tests.rs
create mode 100644 gateways/kafka/tests/list_offsets_real_bridge_tests.rs
create mode 100644 gateways/kafka/tests/metadata_real_bridge_tests.rs
create mode 100644 gateways/kafka/tests/produce_real_bridge_tests.rs
create mode 100644 gateways/kafka/tests/sasl_tests.rs
copy foreign/node/src/wire/command.utils.test.ts =>
web/src/lib/utils/base64Utils.test.mjs (61%)
