This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch chore/bump-patch-edge-after-0.9.0
in repository https://gitbox.apache.org/repos/asf/iggy.git
from d98ef4c2b fixes
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 cf4cccac0 chore: add connector-review skill (#4121)
add bb1ef105e fix(connectors): propagate inner error messages in
RuntimeError (#4342)
add 632b5f24b chore(deps): Bump the github-actions group with 2 updates
(#4353)
add 5c09a0580 chore(deps): Bump the java group across 3 directories with 7
updates (#4352)
add 282b5af18 feat(server): guard against running out of file descriptors
(#4318)
add 8f93cad89 fix(server)!: make logging honor retention, level, path and
file_enabled (#4354)
add 6fe34888d feat(gateways): answer Kafka Fetch with records from Iggy
(#4336)
add 8121e7e2b chore(deps): Bump urllib3 from 2.7.0 to 2.8.0 in
/foreign/python (#4366)
add ed6e6e716 fix(server): prevent panic when the cleaner removes expired
tokens (#4364)
add a08d0ca8f test(sdk): reproduce client lifecycle bugs (#4344)
add 985b0ac1f chore(deps): Bump brace-expansion from 5.0.9 to 5.0.12 in
/foreign/node (#4358)
add 88c842ccc chore(deps): Bump brace-expansion from 5.0.9 to 5.0.12 in
/web (#4359)
add fc927ab28 chore(deps): Bump the web group across 1 directory with 8
updates (#4375)
add 73f1f7023 chore(deps): Bump the node group across 2 directories with 6
updates (#4376)
add db581c276 chore(deps): Bump brace-expansion from 5.0.9 to 5.0.12 in
/examples/node (#4377)
add a6bcfd694 chore(deps): Bump devalue from 5.9.2 to 5.9.4 in /web (#4378)
add d7458b8e6 test(go): cover offset, partition, and consumer group
command serialization (#4370)
add e4ff95b88 feat(go): add GetMe to the Go SDK (#4371)
add 071121c70 fix(consensus): preserve recovery floors and reject aged-out
requests (#4365)
add e51780a53 chore(repo): make repository skills available to Codex
(#4360)
add 7c10d8adb fix(sdk): keep a shut down client shut down (#4374)
add 9d286c639 Merge branch 'master' into chore/bump-patch-edge-after-0.9.0
No new revisions were added by this update.
Summary of changes:
.agents/skills/connector-review | 1 +
.agents/skills/connector-runtime | 1 +
.agents/skills/connector-sdk | 1 +
.agents/skills/connector-sink | 1 +
.agents/skills/connector-source | 1 +
.agents/skills/connector-testing | 1 +
.agents/skills/connector-transform | 1 +
.agents/skills/connectors-overview | 1 +
.agents/skills/team-review | 1 +
.agents/skills/team-review-slim | 1 +
.claude/skills/connector-review/SKILL.md | 237 ++
.../skills/connector-review/agents/openai.yaml | 4 +-
.claude/skills/team-review-slim/SKILL.md | 31 +-
.../skills/team-review-slim/agents/openai.yaml | 4 +-
.claude/skills/team-review/SKILL.md | 29 +-
.../skills/team-review/agents/openai.yaml | 4 +-
.claude/skills/team-review/references/execution.md | 80 +
.config/nextest.toml | 3 +-
.github/actions/go/pre-merge/action.yml | 6 +-
.github/actions/swift/pre-merge/action.yml | 35 +-
.github/config/components.yml | 5 +-
.github/review-bot/README.md | 4 +-
.github/review-bot/prompt.md | 7 +-
.github/workflows/_common.yml | 11 +-
.github/workflows/_test_examples.yml | 2 +-
.github/workflows/codecov-notify.yml | 54 +
.github/workflows/coverage-baseline.yml | 6 +-
.github/workflows/post-merge.yml | 2 +-
.github/workflows/pr-skill-review-post.yml | 53 +-
.github/workflows/pr-skill-review-run.yml | 2 +-
.github/workflows/pr-triage-apply.yml | 24 +-
.github/workflows/pre-merge.yml | 2 +
.gitignore | 2 +
.pre-commit-config.yaml | 8 +-
.typos.toml | 2 +
AGENTS.md | 21 +-
CONTRIBUTING.md | 7 +-
Cargo.lock | 1 +
bdd/java/build.gradle.kts | 4 +-
codecov.yml | 5 +
core/binary_protocol/src/codes.rs | 15 +-
core/binary_protocol/src/consensus/mod.rs | 2 +
core/binary_protocol/src/consensus/request.rs | 143 +
core/binary_protocol/src/dispatch.rs | 203 +-
.../src/requests/messages/flush_unsaved_buffer.rs | 155 --
core/binary_protocol/src/requests/messages/mod.rs | 2 -
.../src/responses/system/get_stats.rs | 46 +-
core/cli/src/args/message.rs | 39 -
.../src/commands/binary_message/flush_messages.rs | 90 -
core/cli/src/commands/binary_message/mod.rs | 1 -
core/cli/src/commands/binary_system/stats.rs | 10 +
core/cli/src/main.rs | 11 +-
core/common/src/error/iggy_error.rs | 23 +
.../src/http/messages/flush_unsaved_buffer.rs | 24 -
core/common/src/http/messages/mod.rs | 1 -
core/common/src/traits/binary_impls/messages.rs | 23 +-
core/common/src/traits/client.rs | 7 +-
core/common/src/traits/consumer_offset_client.rs | 4 +
core/common/src/traits/message_client.rs | 10 -
core/common/src/traits/partition_client.rs | 5 +
core/common/src/traits/segment_client.rs | 7 +-
core/common/src/traits/topic_client.rs | 5 +
core/common/src/types/stats/mod.rs | 11 +
core/common/src/wire_conversions.rs | 2 +
core/configs/src/common/defaults.rs | 11 +
core/configs/src/common/displays.rs | 5 +-
core/configs/src/common/system.rs | 5 +
core/configs/src/common/validators.rs | 101 +-
core/configs/src/server_config/defaults.rs | 2 +
core/configs/src/server_config/displays.rs | 13 +-
core/configs/src/server_config/message_bus.rs | 11 +
core/configs/src/server_config/metadata.rs | 25 +-
core/configs/src/server_config/server.rs | 21 +
core/connectors/runtime/src/error.rs | 50 +-
core/connectors/sinks/delta_sink/README.md | 200 +-
core/connectors/sinks/delta_sink/src/lib.rs | 1 +
core/connectors/sinks/delta_sink/src/sink.rs | 65 +-
core/connectors/sinks/delta_sink/src/storage.rs | 74 +-
core/connectors/sources/http_source/README.md | 3 +-
core/connectors/sources/http_source/src/auth.rs | 3 +-
core/connectors/sources/http_source/src/lib.rs | 11 +-
core/connectors/sources/http_source/src/server.rs | 40 +
core/consensus/src/client_table.rs | 286 +-
core/consensus/src/fatal.rs | 60 -
core/consensus/src/impls.rs | 466 +++-
core/consensus/src/lib.rs | 5 +-
core/consensus/src/observability.rs | 36 +
core/integration/src/harness/config/server.rs | 5 +
core/integration/src/harness/handle/server.rs | 67 +-
core/integration/tests/cli/message/mod.rs | 1 -
.../cli/message/test_message_flush_command.rs | 269 --
.../tests/cli/message/test_message_help_command.rs | 7 +-
.../tests/cli/system/test_stats_command.rs | 22 +-
.../tests/cluster/client_table_restart.rs | 20 +-
core/integration/tests/cluster/partition_dedup.rs | 11 +
.../tests/connectors/delta/delta_sink.rs | 118 +-
.../delta/malformed_table_uri_config}/config.toml | 13 +-
.../malformed_table_uri_sink.toml} | 2 +-
.../missing_secret_key_config/config.toml} | 18 +-
.../missing_secret_key_sink.toml} | 2 +-
.../tests/connectors/fixtures/delta/fixture.rs | 146 +-
.../tests/connectors/fixtures/delta/mod.rs | 5 +-
.../integration/tests/connectors/fixtures/floci.rs | 1 +
.../tests/connectors/fixtures/http/container.rs | 6 +
core/integration/tests/connectors/fixtures/mod.rs | 5 +-
.../tests/connectors/fixtures/wiremock.rs | 6 +
.../tests/connectors/http/http_source.rs | 42 +
.../tests/connectors/runtime/error_isolation.rs | 48 +-
.../sink_missing_stream.toml} | 2 +-
.../stdout_missing_stream.toml} | 14 +-
.../stdout_valid.toml | 0
core/integration/tests/data_integrity/mod.rs | 10 +-
.../verify_cluster_replica_data_identical.rs | 2 +-
core/integration/tests/sdk/client_lifecycle.rs | 176 ++
core/integration/tests/sdk/mod.rs | 1 +
.../tests/server/connections_limit_vsr.rs | 115 +
.../tests/server/descriptor_exhaustion_vsr.rs | 271 ++
core/integration/tests/server/flush_vsr.rs | 69 -
core/integration/tests/server/mod.rs | 10 +-
.../tests/server/partition_view_durability_vsr.rs | 8 +-
.../tests/server/partitions_limit_vsr.rs | 121 +
.../server/personal_access_token_cleaner_vsr.rs | 84 +
.../server/scenarios/authentication_scenario.rs | 5 -
.../tests/server/scenarios/encryption_scenario.rs | 10 +-
.../server/scenarios/log_rotation_scenario.rs | 90 +
.../scenarios/restart_offset_skip_scenario.rs | 5 +-
core/integration/tests/server/stats_vsr.rs | 26 +-
core/journal/src/durable_storage.rs | 21 +-
core/journal/src/file_storage.rs | 15 +-
core/journal/src/partition_journal.rs | 8 +-
core/journal/src/prepare_journal.rs | 302 ++-
core/journal/src/superblock.rs | 16 +-
core/message_bus/src/accept.rs | 89 +
core/message_bus/src/client_listener/mod.rs | 4 +-
core/message_bus/src/client_listener/tcp.rs | 2 +
core/message_bus/src/client_listener/tcp_tls.rs | 2 +
core/message_bus/src/client_listener/ws.rs | 2 +
core/message_bus/src/client_listener/wss.rs | 2 +
core/message_bus/src/connection_cap.rs | 162 ++
core/message_bus/src/installer/mod.rs | 51 +-
core/message_bus/src/installer/quic.rs | 1 +
core/message_bus/src/installer/tcp.rs | 22 +-
core/message_bus/src/installer/tcp_tls.rs | 4 +-
core/message_bus/src/installer/ws.rs | 4 +-
core/message_bus/src/installer/wss.rs | 4 +-
core/message_bus/src/lib.rs | 9 +-
core/message_bus/src/replica/listener.rs | 8 +-
core/message_bus/tests/common/mod.rs | 18 +-
core/message_bus/tests/connection_cap.rs | 100 +
core/message_bus/tests/duplicate_client_id.rs | 10 +-
core/message_bus/tests/installer_panic_cleanup.rs | 3 +
core/metadata/src/impls/metadata.rs | 545 +++-
core/metadata/src/stm/authz.rs | 52 +-
core/metadata/src/stm/stream.rs | 14 +
core/partitions/src/iggy_index_reader.rs | 11 +-
core/partitions/src/iggy_index_writer.rs | 2 +
core/partitions/src/iggy_partition.rs | 411 ++-
core/partitions/src/install_backup.rs | 57 +-
core/partitions/src/lib.rs | 4 +-
core/partitions/src/messages_writer.rs | 2 +
core/partitions/src/offset_recovery.rs | 128 +-
core/partitions/src/offset_storage.rs | 11 +-
core/partitions/src/partition_storage.rs | 323 ++-
core/partitions/src/segment_anchor.rs | 5 +-
core/partitions/src/segment_recovery.rs | 177 +-
core/partitions/src/state_transfer.rs | 114 +-
core/partitions/tests/consumer_offset_history.rs | 529 ++++
.../src/client_wrappers/binary_message_client.rs | 36 -
core/sdk/src/clients/binary_message.rs | 14 -
core/sdk/src/clients/client.rs | 2 +-
core/sdk/src/clients/producer.rs | 242 +-
core/sdk/src/http/http_client.rs | 15 +-
core/sdk/src/http/messages.rs | 34 -
core/sdk/src/poll_routing.rs | 32 +
core/sdk/src/quic/quic_client.rs | 7 +-
core/sdk/src/tcp/tcp_client.rs | 7 +-
core/sdk/src/vsr.rs | 99 +-
core/sdk/src/websocket/websocket_client.rs | 16 +-
core/server/README.md | 62 +
core/server/config.toml | 40 +-
core/server/src/boot/fd_limit.rs | 204 ++
core/server/src/boot/listeners.rs | 45 +-
core/server/src/boot/mod.rs | 51 +-
core/server/src/boot/recovery.rs | 10 +-
core/server/src/boot/threads.rs | 2 +
core/server/src/consumer_group.rs | 4 +-
core/server/src/dispatch/authz.rs | 16 +-
core/server/src/dispatch/host.rs | 3 +
core/server/src/dispatch/mod.rs | 7 +-
core/server/src/dispatch/reads.rs | 2 +-
core/server/src/dispatch/test_support.rs | 17 +-
core/server/src/http.rs | 74 +-
core/server/src/http/extractor.rs | 2 +-
core/server/src/http/handlers.rs | 2 +-
core/server/src/http/reads.rs | 3 +-
core/server/src/http/session.rs | 7 +-
core/server/src/http/state.rs | 43 +-
core/server/src/http/submit.rs | 6 +-
core/server/src/http/tls.rs | 50 +-
core/server/src/lib.rs | 1 +
core/server/src/main.rs | 35 +-
core/server/src/partition_helpers.rs | 900 ++++++-
core/server/src/partition_reconciler.rs | 84 +-
core/server/src/responses.rs | 31 +-
core/server/src/server_error.rs | 26 +
core/server/src/session_manager.rs | 9 +
core/server/src/snapshot.rs | 13 +-
core/server/src/sysinfo_printer.rs | 208 ++
core/server/src/sysinfo_probe.rs | 134 +-
core/server_common/Cargo.toml | 1 +
core/server_common/src/fatal.rs | 237 ++
core/server_common/src/lib.rs | 5 +-
core/server_common/src/log/logger.rs | 294 +-
core/server_common/src/log/mod.rs | 2 +-
core/server_common/src/log/settings.rs | 124 +
.../src/segment_storage/index_reader.rs | 26 +-
.../src/segment_storage/index_writer.rs | 103 -
.../src/segment_storage/messages_reader.rs | 4 +
.../src/segment_storage/messages_writer.rs | 120 -
core/server_common/src/segment_storage/mod.rs | 122 +-
core/shard/src/builder.rs | 1 +
core/shard/src/coordinator.rs | 468 ++--
core/shard/src/lib.rs | 111 +-
core/shard/src/router.rs | 34 +-
core/simulator/src/bus.rs | 15 +-
.../simulator/src/consumer_offset_history_tests.rs | 220 ++
core/simulator/src/lib.rs | 329 ++-
core/system_stats/src/lib.rs | 86 +-
examples/java/build.gradle.kts | 4 +-
examples/node/package-lock.json | 26 +-
examples/node/package.json | 4 +-
foreign/cpp/include/iggy.hpp | 1701 +++++++++++-
foreign/cpp/src/client.cpp | 77 +
foreign/cpp/src/client.rs | 31 +-
foreign/cpp/src/lib.rs | 14 +-
foreign/cpp/src/type_conversion.rs | 4 +
foreign/cpp/src/type_conversions.cpp | 174 ++
foreign/cpp/tests/e2e/client.cpp | 2832 +++++++++-----------
foreign/cpp/tests/e2e/consumer_group.cpp | 12 +-
foreign/cpp/tests/e2e/stream.cpp | 20 +-
foreign/cpp/tests/e2e/test_helpers.hpp | 10 +
foreign/cpp/tests/unit/unit_tests.cpp | 11 +
foreign/csharp/Directory.Packages.props | 8 +-
.../FlushMessagesTests.cs | 40 -
.../Iggy_SDK.Tests.Integration/SystemTests.cs | 1 +
.../Iggy_SDK/Contracts/Auth/GlobalPermissions.cs | 3 -
foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs | 10 +
.../csharp/Iggy_SDK/Contracts/StreamPermissions.cs | 3 -
.../csharp/Iggy_SDK/Contracts/TopicPermissions.cs | 3 -
.../VsrRequestOutcomeUnknownException.cs | 9 +-
.../csharp/Iggy_SDK/IggyClient/IIggyPublisher.cs | 17 -
foreign/csharp/Iggy_SDK/IggyClient/IIggySegment.cs | 6 +-
.../Implementations/HttpMessageStream.cs | 19 +-
.../Implementations/TcpMessageStream.Vsr.cs | 13 +-
.../IggyClient/Implementations/TcpMessageStream.cs | 10 -
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 6 +-
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 22 +-
.../Publishers/BackgroundMessageProcessor.cs | 5 +-
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 1 -
foreign/csharp/Iggy_SDK/Vsr/ConsensusSession.cs | 4 +-
foreign/csharp/Iggy_SDK/Vsr/VsrError.cs | 1 +
foreign/csharp/Iggy_SDK/Vsr/VsrOperation.cs | 4 +-
.../ClientTests/HttpTopicOptionsTests.cs | 19 +
.../Iggy_SDK_Tests/MapperTests/BinaryMapper.cs | 28 +
.../Iggy_SDK_Tests/UtilityTests/SendUnitTests.cs | 24 +
.../csharp/Iggy_SDK_Tests/Utils/BinaryFactory.cs | 67 +-
.../Iggy_SDK_Tests/Utils/Stats/StatsFactory.cs | 7 +-
.../VsrTests/EndpointFailoverTests.cs | 45 +
foreign/csharp/README.md | 3 +-
foreign/csharp/README.nuget.md | 19 +
foreign/go/client/tcp/tcp_clients_management.go | 9 +
foreign/go/contracts/client.go | 4 +
foreign/go/contracts/stats.go | 8 +
foreign/go/contracts/stats_test.go | 39 +-
foreign/go/errors/errors.yaml | 8 +
foreign/go/errors/errors_gen.go | 34 +
foreign/go/errors/errors_test.go | 6 +
foreign/go/internal/command/consumer_group_test.go | 130 +
foreign/go/internal/command/offset_test.go | 120 +
foreign/go/internal/command/partition_test.go | 89 +
foreign/go/internal/command/session_test.go | 33 +
foreign/go/internal/command/system.go | 12 +
foreign/go/internal/command/system_test.go | 106 +
foreign/go/internal/command/user_test.go | 75 +
foreign/go/internal/vsr/envelope.go | 6 +-
foreign/go/internal/vsr/protocol_parity_test.go | 7 +-
foreign/go/tests/e2e_test.go | 38 +-
foreign/java/gradle/libs.versions.toml | 8 +-
.../apache/iggy/client/async/tcp/PollRouter.java | 32 +-
.../client/async/tcp/vsr/VsrRequestEncoder.java | 5 +-
.../org/apache/iggy/exception/IggyErrorCode.java | 7 +
.../org/apache/iggy/serde/BytesDeserializer.java | 17 +-
.../main/java/org/apache/iggy/system/Stats.java | 9 +-
.../AsyncIggyTcpClientTransientFailoverTest.java | 57 +-
.../iggy/client/blocking/SystemClientBaseTest.java | 2 +
.../client/blocking/http/ObjectMapperTest.java | 51 +-
.../apache/iggy/exception/IggyErrorCodeTest.java | 2 +
.../apache/iggy/serde/BytesDeserializerTest.java | 41 +
foreign/node/package-lock.json | 321 +--
foreign/node/package.json | 6 +-
foreign/node/src/e2e/tcp.parallel.e2e.ts | 5 +-
foreign/node/src/e2e/tcp.system.e2e.ts | 5 +-
foreign/node/src/wire/command-set.ts | 4 +-
foreign/node/src/wire/command.code.ts | 1 -
foreign/node/src/wire/error.code.test.ts | 11 +
foreign/node/src/wire/error.code.ts | 2 +
.../wire/message/flush-unsaved-buffers.command.ts | 53 -
foreign/node/src/wire/message/message.utils.ts | 30 +-
.../node/src/wire/system/get-stats.command.test.ts | 127 +
foreign/node/src/wire/system/get-stats.command.ts | 127 +-
foreign/node/src/wire/vsr/index.ts | 5 +-
foreign/python/apache_iggy.pyi | 46 +
foreign/python/src/client.rs | 42 +
foreign/python/src/stats.rs | 20 +
foreign/python/tests/test_connectivity.py | 170 +-
foreign/python/tests/test_stats.py | 4 +
foreign/python/uv.lock | 6 +-
foreign/swift/Package.swift | 3 +-
foreign/swift/README.md | 15 +-
.../swift/Sources/Iggy/Errors/IggyErrorCode.swift | 8 +-
.../swift/Sources/Iggy/Hash/UnalignedLoads.swift | 18 +-
foreign/swift/Sources/Iggy/Hash/XXH3.swift | 273 ++
foreign/swift/Sources/Iggy/Hash/XXH32.swift | 79 +
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 | 634 +++++
.../swift/Sources/Iggy/Models/TopicOptions.swift | 206 ++
.../swift/Sources/Iggy/Models/UserHeaders.swift | 427 +++
foreign/swift/Sources/Iggy/Wire/ByteCodec.swift | 7 +
foreign/swift/Tests/IggyTests/ErrorCodeTests.swift | 19 +-
foreign/swift/Tests/IggyTests/Fixtures/golden.json | 1008 +++++++
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 | 1442 ++++++++++
gateways/kafka/Cargo.toml | 2 +
gateways/kafka/README.md | 147 +-
gateways/kafka/docs/ACL_MAPPING.md | 6 +-
gateways/kafka/docs/AUTHENTICATION.md | 10 +-
gateways/kafka/docs/BRIDGE_MAPPING.md | 10 +-
gateways/kafka/docs/CONSUMER_GROUPS.md | 4 +-
gateways/kafka/docs/IDEMPOTENCE.md | 22 +-
gateways/kafka/docs/MANUAL_TESTING.md | 2 +-
gateways/kafka/docs/OFFSET_STORAGE.md | 49 +-
gateways/kafka/docs/SCOPE.md | 49 +-
gateways/kafka/docs/TEST_SUITE.md | 6 +-
gateways/kafka/docs/kafka_api_keys_reference.md | 9 +-
gateways/kafka/src/bridge/error.rs | 39 +-
gateways/kafka/src/bridge/iggy_bridge/fetch.rs | 468 +++-
gateways/kafka/src/bridge/iggy_bridge/mod.rs | 90 +-
gateways/kafka/src/bridge/iggy_bridge/offsets.rs | 141 +-
gateways/kafka/src/bridge/iggy_bridge/produce.rs | 33 +-
gateways/kafka/src/bridge/mod.rs | 4 +-
gateways/kafka/src/protocol/api.rs | 57 +-
.../kafka/src/protocol/handlers/create_topics.rs | 17 +-
gateways/kafka/src/protocol/handlers/fetch.rs | 2830 ++++++++++++++++++-
.../kafka/src/protocol/handlers/list_offsets.rs | 120 +-
gateways/kafka/src/protocol/handlers/metadata.rs | 14 +-
gateways/kafka/src/protocol/handlers/mod.rs | 82 +-
gateways/kafka/src/protocol/handlers/produce.rs | 57 +-
gateways/kafka/src/protocol/mod.rs | 1 +
gateways/kafka/src/protocol/probe_board.rs | 468 ++++
gateways/kafka/src/records.rs | 110 +-
gateways/kafka/src/server.rs | 21 +-
gateways/kafka/tests/fetch_real_bridge_tests.rs | 821 ++++++
gateways/kafka/tests/kafka_client_e2e_tests.rs | 211 +-
gateways/kafka/tools/kafka-tool/README.md | 10 +-
scripts/ci/skills.sh | 104 +-
web/package-lock.json | 379 +--
web/package.json | 18 +-
375 files changed, 26455 insertions(+), 5944 deletions(-)
create mode 120000 .agents/skills/connector-review
create mode 120000 .agents/skills/connector-runtime
create mode 120000 .agents/skills/connector-sdk
create mode 120000 .agents/skills/connector-sink
create mode 120000 .agents/skills/connector-source
create mode 120000 .agents/skills/connector-testing
create mode 120000 .agents/skills/connector-transform
create mode 120000 .agents/skills/connectors-overview
create mode 120000 .agents/skills/team-review
create mode 120000 .agents/skills/team-review-slim
create mode 100644 .claude/skills/connector-review/SKILL.md
copy examples/java/gradle.properties =>
.claude/skills/connector-review/agents/openai.yaml (94%)
copy examples/java/gradle.properties =>
.claude/skills/team-review-slim/agents/openai.yaml (94%)
copy examples/java/gradle.properties =>
.claude/skills/team-review/agents/openai.yaml (94%)
create mode 100644 .claude/skills/team-review/references/execution.md
create mode 100644 .github/workflows/codecov-notify.yml
create mode 100644 core/binary_protocol/src/consensus/request.rs
delete mode 100644
core/binary_protocol/src/requests/messages/flush_unsaved_buffer.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
delete mode 100644 core/consensus/src/fatal.rs
delete mode 100644
core/integration/tests/cli/message/test_message_flush_command.rs
copy core/{connectors/sinks/stdout_sink =>
integration/tests/connectors/delta/malformed_table_uri_config}/config.toml (74%)
copy core/integration/tests/connectors/{clickhouse/sink.toml =>
delta/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/{clickhouse/sink.toml =>
delta/missing_secret_key_sink.toml} (92%)
copy core/integration/tests/connectors/{iceberg/sink_default_credentials.toml
=> runtime/sink_missing_stream.toml} (92%)
copy
core/integration/tests/connectors/runtime/{sink_invalid_config/stdout_valid.toml
=> sink_missing_stream_config/stdout_missing_stream.toml} (75%)
copy core/integration/tests/connectors/runtime/{sink_invalid_config =>
sink_missing_stream_config}/stdout_valid.toml (100%)
create mode 100644 core/integration/tests/sdk/client_lifecycle.rs
create mode 100644 core/integration/tests/server/connections_limit_vsr.rs
create mode 100644 core/integration/tests/server/descriptor_exhaustion_vsr.rs
delete mode 100644 core/integration/tests/server/flush_vsr.rs
create mode 100644 core/integration/tests/server/partitions_limit_vsr.rs
create mode 100644
core/integration/tests/server/personal_access_token_cleaner_vsr.rs
create mode 100644 core/message_bus/src/accept.rs
create mode 100644 core/message_bus/src/connection_cap.rs
create mode 100644 core/message_bus/tests/connection_cap.rs
create mode 100644 core/partitions/tests/consumer_offset_history.rs
create mode 100644 core/server/src/boot/fd_limit.rs
create mode 100644 core/server/src/sysinfo_printer.rs
create mode 100644 core/server_common/src/fatal.rs
delete mode 100644 core/server_common/src/segment_storage/index_writer.rs
delete mode 100644 core/server_common/src/segment_storage/messages_writer.rs
create mode 100644 core/simulator/src/consumer_offset_history_tests.rs
delete mode 100644
foreign/csharp/Iggy_SDK.Tests.Integration/FlushMessagesTests.cs
create mode 100644 foreign/csharp/README.nuget.md
create mode 100644 foreign/go/internal/command/consumer_group_test.go
create mode 100644 foreign/go/internal/command/offset_test.go
create mode 100644 foreign/go/internal/command/partition_test.go
create mode 100644 foreign/go/internal/command/system_test.go
delete mode 100644
foreign/node/src/wire/message/flush-unsaved-buffers.command.ts
create mode 100644 foreign/node/src/wire/system/get-stats.command.test.ts
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
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/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/src/protocol/probe_board.rs
create mode 100644 gateways/kafka/tests/fetch_real_bridge_tests.rs
