This is an automated email from the ASF dual-hosted git repository.
hubcio pushed a change to branch fix/bench-warmup-pacing
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit 9bafdc325 fix(bench): pace warmup, rewind offsets, repair rate limiter
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 0936d44cc chore(repo): bump all components to patch edge versions
after 0.9.0 (#4315)
add 815f345b3 docs: require agent review, comment replies and fewer
rebases (#4384)
add c80183499 chore(deps): Bump the go group across 2 directories with 2
updates (#4390)
add 2d7fddba5 feat(gateways): Kafka gateway Phase 1 quick-start and Docker
Compose E2E (#4372)
add f03ee4614 ci(repo): upgrade Cargo-Rail planning to v0.30.1 (#3999)
add a2895fdc6 feat(cpp): add code coverage (#4118)
add f6dfbdbb3 feat(server): store offsets of groups managed outside Iggy
(#4392)
add 39c2c9af1 fix(bench): pace warmup and rewind consumers
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 (9bafdc325)
\
N -- N -- N refs/heads/fix/bench-warmup-pacing (39c2c9af1)
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:
.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/connector-sink/TEMPLATE.md | 2 +-
.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 | 6 +-
.config/rail.toml | 36 +-
.github/actions/cpp-bazel/pre-merge/action.yml | 16 +-
.github/actions/go/pre-merge/action.yml | 6 +-
.github/actions/rust/pre-merge/action.yml | 252 +-
.github/config/edge-image-variants.json | 117 +
.github/config/publish.yml | 28 +-
.github/workflows/_common.yml | 40 +-
.github/workflows/_test.yml | 18 +-
.github/workflows/_test_examples.yml | 2 +-
.github/workflows/coverage-baseline.yml | 34 +-
.github/workflows/post-merge.yml | 61 +-
.github/workflows/pre-merge.yml | 2 +
.github/workflows/publish.yml | 2 +-
.../connectors/.gitkeep => .pr4372-comments.json | 0
.pre-commit-config.yaml | 8 +-
AGENTS.md | 21 +-
CONTRIBUTING.md | 22 +
Cargo.lock | 67 +-
Cargo.toml | 10 +-
bdd/go/go.mod | 4 +-
bdd/go/go.sum | 8 +-
bdd/java/build.gradle.kts | 4 +-
bdd/python/uv.lock | 2 +-
codecov.yml | 7 +
core/ai/mcp/Cargo.toml | 2 +-
core/bench/Cargo.toml | 2 +-
core/bench/dashboard/frontend/Cargo.toml | 2 +-
core/bench/dashboard/server/Cargo.toml | 2 +-
core/bench/report/Cargo.toml | 2 +-
.../src/actors/consumer/benchmark_consumer.rs | 95 +
.../bench/src/actors/consumer/client/high_level.rs | 7 +-
.../benchmark_producing_consumer.rs | 317 +--
core/binary_protocol/Cargo.toml | 2 +-
core/binary_protocol/src/lib.rs | 4 +-
core/binary_protocol/src/primitives/consumer.rs | 29 +-
.../src/responses/system/get_stats.rs | 46 +-
core/cli/Cargo.toml | 2 +-
core/cli/src/args/consumer_offset.rs | 6 +-
.../binary_consumer_offsets/get_consumer_offset.rs | 1 +
core/cli/src/commands/binary_system/stats.rs | 10 +
core/common/Cargo.toml | 2 +-
core/common/src/error/iggy_error.rs | 23 +
core/common/src/traits/client.rs | 7 +-
core/common/src/traits/consumer_offset_client.rs | 6 +
core/common/src/traits/message_client.rs | 1 +
core/common/src/traits/partition_client.rs | 5 +
core/common/src/traits/topic_client.rs | 5 +
core/common/src/types/consumer/consumer_kind.rs | 78 +-
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/Cargo.toml | 2 +-
core/connectors/runtime/src/error.rs | 50 +-
core/connectors/sdk/Cargo.toml | 2 +-
core/connectors/sinks/clickhouse_sink/Cargo.toml | 2 +-
core/connectors/sinks/delta_sink/Cargo.toml | 2 +-
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/sinks/doris_sink/Cargo.toml | 2 +-
.../connectors/sinks/elasticsearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/http_sink/Cargo.toml | 2 +-
core/connectors/sinks/iceberg_sink/Cargo.toml | 2 +-
core/connectors/sinks/influxdb_sink/Cargo.toml | 2 +-
core/connectors/sinks/meilisearch_sink/Cargo.toml | 2 +-
core/connectors/sinks/mongodb_sink/Cargo.toml | 2 +-
core/connectors/sinks/postgres_sink/Cargo.toml | 2 +-
core/connectors/sinks/quickwit_sink/Cargo.toml | 2 +-
core/connectors/sinks/rabbitmq_sink/Cargo.toml | 2 +-
core/connectors/sinks/redshift_sink/Cargo.toml | 2 +-
core/connectors/sinks/s3_sink/Cargo.toml | 2 +-
core/connectors/sinks/stdout_sink/Cargo.toml | 2 +-
core/connectors/sinks/surrealdb_sink/Cargo.toml | 2 +-
.../sources/elasticsearch_source/Cargo.toml | 2 +-
core/connectors/sources/http_source/Cargo.toml | 2 +-
core/connectors/sources/influxdb_source/Cargo.toml | 2 +-
core/connectors/sources/postgres_source/Cargo.toml | 2 +-
core/connectors/sources/random_source/Cargo.toml | 2 +-
core/consensus/src/client_table.rs | 286 +-
core/consensus/src/fatal.rs | 60 -
core/consensus/src/impls.rs | 446 ++-
core/consensus/src/lib.rs | 5 +-
core/consensus/src/observability.rs | 36 +
core/integration/src/harness/config/server.rs | 5 +
core/integration/src/harness/disk.rs | 1 +
core/integration/src/harness/handle/server.rs | 67 +-
core/integration/tests/cli/consumer_offset/mod.rs | 1 +
.../test_consumer_offset_external_group_command.rs | 149 ++
.../test_consumer_offset_get_command.rs | 6 +-
.../test_consumer_offset_set_command.rs | 6 +-
.../tests/cli/system/test_stats_command.rs | 22 +-
core/integration/tests/cluster/partition_dedup.rs | 11 +
.../tests/cluster/partition_state_transfer.rs | 52 +-
.../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 +
core/integration/tests/connectors/fixtures/mod.rs | 5 +-
.../tests/connectors/runtime/error_isolation.rs | 48 +-
.../sink_missing_stream.toml} | 2 +-
.../stdout_missing_stream.toml} | 14 +-
.../stdout_valid.toml | 0
core/integration/tests/sdk/client_lifecycle.rs | 176 ++
core/integration/tests/sdk/mod.rs | 1 +
core/integration/tests/server/cg.rs | 10 +-
.../tests/server/connections_limit_vsr.rs | 115 +
.../tests/server/descriptor_exhaustion_vsr.rs | 271 ++
core/integration/tests/server/mod.rs | 8 +
.../tests/server/partition_view_durability_vsr.rs | 8 +-
.../tests/server/partitions_limit_vsr.rs | 121 +
.../server/personal_access_token_cleaner_vsr.rs | 84 +
.../scenarios/external_group_offsets_scenario.rs | 142 +
.../server/scenarios/log_rotation_scenario.rs | 90 +
core/integration/tests/server/scenarios/mod.rs | 1 +
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/consumer_offset_capacity.rs | 3 +
core/partitions/src/iggy_index_reader.rs | 11 +-
core/partitions/src/iggy_index_writer.rs | 2 +
core/partitions/src/iggy_partition.rs | 2147 ++++++++++-----
core/partitions/src/iggy_partitions.rs | 14 +
core/partitions/src/install_backup.rs | 57 +-
core/partitions/src/lib.rs | 5 +-
core/partitions/src/messages_writer.rs | 2 +
core/partitions/src/offset_recovery.rs | 145 +-
core/partitions/src/offset_storage.rs | 11 +-
core/partitions/src/partition_storage.rs | 589 +++-
core/partitions/src/persistence.rs | 5 +-
core/partitions/src/segment_anchor.rs | 5 +-
core/partitions/src/segment_recovery.rs | 200 +-
core/partitions/src/state_transfer.rs | 579 ++--
core/partitions/src/types.rs | 15 +
core/partitions/tests/consumer_offset_history.rs | 1 +
core/sdk/Cargo.toml | 2 +-
core/sdk/src/clients/producer.rs | 242 +-
core/sdk/src/http/consumer_offsets.rs | 72 +-
core/sdk/src/http/http_client.rs | 15 +-
core/sdk/src/http/messages.rs | 1 +
core/sdk/src/quic/quic_client.rs | 7 +-
.../stream_builder/build/build_iggy_consumer.rs | 3 +
.../stream_builder/config/config_iggy_consumer.rs | 41 +-
core/sdk/src/stream_builder/iggy_stream.rs | 35 +-
.../sdk/src/stream_builder/iggy_stream_consumer.rs | 28 +-
core/sdk/src/tcp/tcp_client.rs | 7 +-
core/sdk/src/vsr.rs | 28 +-
core/sdk/src/websocket/websocket_client.rs | 16 +-
core/server/Cargo.toml | 2 +-
core/server/README.md | 68 +
core/server/config.toml | 46 +-
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 | 26 +-
core/server/src/dispatch/host.rs | 3 +
core/server/src/dispatch/mod.rs | 7 +-
core/server/src/dispatch/partition.rs | 65 +-
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 | 11 +-
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/namespace.rs | 18 +-
core/server/src/partition_helpers.rs | 900 ++++++-
core/server/src/partition_reconciler.rs | 106 +-
core/server/src/responses.rs | 4 +-
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 | 131 +-
core/shard/src/metrics.rs | 58 +-
core/shard/src/poll.rs | 8 +
core/shard/src/router.rs | 57 +-
core/simulator/src/bus.rs | 15 +-
.../simulator/src/consumer_offset_history_tests.rs | 1 +
core/simulator/src/lib.rs | 328 ++-
core/simulator/src/storage/purge.rs | 226 +-
core/simulator/src/workload/ops/mod.rs | 25 +-
.../src/workload/ops/store_consumer_offset.rs | 2 +-
core/system_stats/src/lib.rs | 86 +-
examples/go/go.mod | 2 +-
examples/go/go.sum | 4 +-
examples/java/build.gradle.kts | 4 +-
examples/node/package-lock.json | 28 +-
examples/node/package.json | 4 +-
examples/python/uv.lock | 2 +-
examples/rust/src/new-sdk/consumer/main.rs | 1 +
foreign/cpp/BUILD.bazel | 50 +-
foreign/cpp/MODULE.bazel | 17 +
foreign/cpp/MODULE.bazel.lock | 2 +-
foreign/cpp/include/iggy.hpp | 22 +-
foreign/cpp/src/lib.rs | 4 +
foreign/cpp/src/type_conversion.rs | 2 +
foreign/cpp/src/type_conversions.cpp | 3 +-
foreign/cpp/tests/e2e/client.cpp | 2 +
.../Iggy_SDK.Tests.Integration/SystemTests.cs | 1 +
foreign/csharp/Iggy_SDK/Contracts/StatsResponse.cs | 10 +
.../VsrRequestOutcomeUnknownException.cs | 9 +-
.../Implementations/HttpMessageStream.cs | 9 +-
.../Implementations/TcpMessageStream.Vsr.cs | 13 +-
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 2 +-
foreign/csharp/Iggy_SDK/Mappers/BinaryMapper.cs | 22 +-
.../Publishers/BackgroundMessageProcessor.cs | 5 +-
foreign/csharp/Iggy_SDK/Vsr/ConsensusSession.cs | 4 +-
foreign/csharp/Iggy_SDK/Vsr/VsrError.cs | 1 +
.../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 +
.../VsrTests/VsrProtocolDriftTests.cs | 3 +-
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/contracts/version.go | 2 +-
foreign/go/errors/errors.yaml | 8 +
foreign/go/errors/errors_gen.go | 34 +
foreign/go/errors/errors_test.go | 6 +
foreign/go/go.mod | 2 +-
foreign/go/go.sum | 4 +-
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/system.go | 12 +
foreign/go/internal/command/system_test.go | 1 +
foreign/go/internal/vsr/envelope.go | 6 +-
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 | 325 +--
foreign/node/package.json | 8 +-
foreign/node/src/e2e/tcp.parallel.e2e.ts | 5 +-
foreign/node/src/e2e/tcp.system.e2e.ts | 5 +-
foreign/node/src/wire/error.code.test.ts | 11 +
foreign/node/src/wire/error.code.ts | 2 +
.../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/Cargo.toml | 4 +-
foreign/python/apache_iggy.pyi | 20 +-
foreign/python/pyproject.toml | 2 +-
foreign/python/src/client.rs | 4 -
foreign/python/src/stats.rs | 20 +
foreign/python/tests/test_connectivity.py | 17 +-
foreign/python/tests/test_stats.py | 4 +
foreign/python/uv.lock | 8 +-
foreign/swift/README.md | 8 +-
.../swift/Sources/Iggy/Errors/IggyErrorCode.swift | 4 +
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 | 1 +
foreign/swift/Tests/IggyTests/Fixtures/golden.json | 18 +-
foreign/swift/Tests/IggyTests/ModelTests.swift | 379 +++
.../swift/Tests/IggyTests/ModelVectorTests.swift | 116 +
.../Tests/IggyTests/Support/GoldenFixture.swift | 32 +
foreign/swift/Tools/golden-vectors/src/main.rs | 9 +-
gateways/kafka/Cargo.toml | 2 +
gateways/kafka/Dockerfile | 64 +
.../kafka/Dockerfile.dockerignore | 36 +-
gateways/kafka/README.md | 245 +-
gateways/kafka/docker-compose.yml | 141 +
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 | 37 +-
gateways/kafka/docs/SCOPE.md | 22 +-
gateways/kafka/docs/TEST_SUITE.md | 23 +-
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/common/gateway_process.rs | 102 +
gateways/kafka/tests/common/iggy_server.rs | 86 +-
gateways/kafka/tests/fetch_real_bridge_tests.rs | 821 ++++++
gateways/kafka/tests/kafka_client_e2e_tests.rs | 211 +-
gateways/kafka/tests/phase1_e2e_tests.rs | 341 +++
licenserc.toml | 1 +
scripts/ci/coverage-baseline-affected.sh | 6 +-
scripts/ci/cpp-coverage.sh | 84 +
scripts/ci/edge-affected-images.sh | 150 --
scripts/ci/edge-image-catalog.sh | 88 +
scripts/ci/skills.sh | 104 +-
scripts/ci/sync-rustc-version.sh | 21 +
web/package-lock.json | 383 +--
web/package.json | 20 +-
399 files changed, 22988 insertions(+), 4687 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/config/edge-image-variants.json
copy core/integration/tests/connectors/api/connectors/.gitkeep =>
.pr4372-comments.json (100%)
delete mode 100644 core/consensus/src/fatal.rs
create mode 100644
core/integration/tests/cli/consumer_offset/test_consumer_offset_external_group_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
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/integration/tests/server/scenarios/external_group_offsets_scenario.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/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 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/node/src/wire/system/get-stats.command.test.ts
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/ModelTests.swift
create mode 100644 foreign/swift/Tests/IggyTests/ModelVectorTests.swift
create mode 100644 gateways/kafka/Dockerfile
copy core/ai/mcp/.dockerignore => gateways/kafka/Dockerfile.dockerignore (57%)
create mode 100644 gateways/kafka/docker-compose.yml
create mode 100644 gateways/kafka/src/protocol/probe_board.rs
create mode 100644 gateways/kafka/tests/common/gateway_process.rs
create mode 100644 gateways/kafka/tests/fetch_real_bridge_tests.rs
create mode 100644 gateways/kafka/tests/phase1_e2e_tests.rs
create mode 100755 scripts/ci/cpp-coverage.sh
delete mode 100755 scripts/ci/edge-affected-images.sh
create mode 100755 scripts/ci/edge-image-catalog.sh
