This is an automated email from the ASF dual-hosted git repository.
slbotbm pushed a change to branch cpp-high-level-client-3
in repository https://gitbox.apache.org/repos/asf/iggy.git
omit b64599e24 fixes
omit ec9506ee8 remove docs and add test
omit 4514186d6 align cpp sdk with rust, add docs
omit ba8b76cc5 add functions
omit 6a126924e migrate functions
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 947df6ab2 migrate functions
add a08e71d7f add functions
add f8c121731 align cpp sdk with rust, add docs
add 3e79e8300 remove docs and add test
add f8911cdbd 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 (b64599e24)
\
N -- N -- N refs/heads/cpp-high-level-client-3 (f8911cdbd)
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-runtime/SKILL.md | 5 +-
.claude/skills/connector-sdk/SKILL.md | 17 +-
.claude/skills/connector-sink/SKILL.md | 2 +-
.config/nextest.toml | 22 +-
.github/actions/rust/pre-merge/action.yml | 23 +
.github/actions/swift/pre-merge/action.yml | 104 +
.github/actions/utils/setup-swift/action.yml | 56 +
.github/config/components.yml | 11 +
.github/review-bot/README.md | 69 +
.github/review-bot/comment-style.md | 43 +
.github/review-bot/prompt.md | 73 +
.github/workflows/_common.yml | 6 +-
.github/workflows/_detect.yml | 11 +-
.github/workflows/_test.yml | 24 +-
.github/workflows/_test_examples.yml | 2 +-
.github/workflows/coverage-baseline.yml | 20 +-
.github/workflows/post-merge.yml | 2 +-
.github/workflows/pr-skill-review-post.yml | 504 ++++
.github/workflows/pr-skill-review-run.yml | 542 ++++
.github/workflows/pr-triage-apply.yml | 257 +-
.github/workflows/pr-triage-collect.yml | 6 +-
.github/workflows/pre-merge.yml | 21 +-
.github/workflows/publish.yml | 2 +-
.github/workflows/stale-prs-unmark-on-activity.yml | 101 +-
.gitignore | 10 +
.typos.toml | 2 +
AGENTS.md | 14 +-
CONTRIBUTING.md | 16 +-
Cargo.lock | 39 +-
Cargo.toml | 7 +-
bdd/docker-compose.cluster.yml | 1 +
bdd/go/go.mod | 4 +-
bdd/go/go.sum | 8 +-
bdd/python/uv.lock | 64 +-
core/binary_protocol/src/codes.rs | 15 +-
core/binary_protocol/src/consensus/command.rs | 11 +-
.../src/consensus/consumer_session.rs | 218 ++
core/binary_protocol/src/consensus/header.rs | 6 +
core/binary_protocol/src/consensus/mod.rs | 6 +
core/binary_protocol/src/consensus/request.rs | 143 +
core/binary_protocol/src/dispatch.rs | 203 +-
core/binary_protocol/src/lib.rs | 22 +-
.../src/requests/messages/flush_unsaved_buffer.rs | 155 -
core/binary_protocol/src/requests/messages/mod.rs | 2 -
core/cli/src/args/consumer_group.rs | 6 +-
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/main.rs | 11 +-
.../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/consumer_offset_client.rs | 4 +
core/common/src/traits/message_client.rs | 10 -
core/configs/src/common/defaults.rs | 10 +
core/configs/src/common/displays.rs | 6 +-
core/configs/src/common/server.rs | 7 +
core/configs/src/common/system.rs | 3 -
core/configs/src/server_config/server.rs | 76 +-
core/configs/src/server_config/validators.rs | 391 ++-
core/connectors/runtime/Cargo.toml | 4 +
core/connectors/runtime/README.md | 5 +-
core/connectors/runtime/src/benchmark.rs | 5 +-
core/connectors/runtime/src/metrics.rs | 34 +-
core/connectors/runtime/src/sink.rs | 669 ++++-
core/connectors/sdk/Cargo.toml | 2 +-
core/connectors/sdk/README.md | 15 +-
core/connectors/sdk/src/lib.rs | 334 ++-
core/connectors/sdk/src/sink.rs | 149 +-
.../sdk/src/transforms/flatbuffer_convert.rs | 23 +-
.../connectors/sdk/src/transforms/proto_convert.rs | 65 +-
core/connectors/sinks/README.md | 8 +
core/connectors/sinks/clickhouse_sink/README.md | 8 +-
core/connectors/sinks/clickhouse_sink/src/body.rs | 110 +-
core/connectors/sinks/delta_sink/Cargo.toml | 3 +
core/connectors/sinks/delta_sink/src/sink.rs | 81 +-
core/connectors/sinks/doris_sink/README.md | 3 +-
core/connectors/sinks/doris_sink/src/lib.rs | 87 +-
.../connectors/sinks/elasticsearch_sink/src/lib.rs | 80 +-
core/connectors/sinks/http_sink/README.md | 3 +-
core/connectors/sinks/http_sink/src/lib.rs | 37 +-
.../iceberg_sink/src/router/dynamic_router.rs | 58 +-
.../sinks/iceberg_sink/src/router/mod.rs | 43 +-
.../connectors/sinks/influxdb_sink/dependencies.md | 2 +-
core/connectors/sinks/meilisearch_sink/README.md | 13 +-
core/connectors/sinks/meilisearch_sink/src/lib.rs | 38 +-
core/connectors/sinks/quickwit_sink/README.md | 2 +-
core/connectors/sinks/quickwit_sink/src/lib.rs | 22 +-
core/connectors/sinks/redshift_sink/README.md | 2 +-
core/connectors/sinks/s3_sink/README.md | 2 +-
core/connectors/sinks/s3_sink/src/formatter.rs | 28 +-
core/connectors/sinks/surrealdb_sink/README.md | 11 +-
core/connectors/sinks/surrealdb_sink/src/lib.rs | 17 +
.../sources/influxdb_source/dependencies.md | 2 +-
core/consensus/src/impls.rs | 20 +
core/integration/Cargo.toml | 1 +
.../test_consumer_group_create_command.rs | 34 +-
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/cluster/client_table_restart.rs | 478 +++-
.../tests/cluster/crash_recovery_corruption.rs | 2 +-
.../tests/cluster/partition_primary_routing.rs | 29 +-
.../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 +-
core/integration/tests/connectors/doris/mod.rs | 1 +
.../meilisearch_sink.rs => doris/proto_text.rs} | 56 +-
.../{delta/sink.toml => doris/proto_text.toml} | 2 +-
.../proto_text_config/doris_sink.toml} | 35 +-
.../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} | 23 +-
.../tests/connectors/fixtures/delta/fixture.rs | 158 +-
.../integration/tests/connectors/fixtures/floci.rs | 159 ++
.../tests/connectors/fixtures/http/container.rs | 6 +
.../tests/connectors/fixtures/iceberg/container.rs | 166 +-
core/integration/tests/connectors/fixtures/mod.rs | 1 +
.../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/wiremock.rs | 6 +
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 +-
core/integration/tests/connectors/s3/s3_sink.rs | 33 +-
core/integration/tests/data_integrity/mod.rs | 10 +-
.../verify_cluster_replica_data_identical.rs | 2 +-
core/integration/tests/server/flush_vsr.rs | 69 -
core/integration/tests/server/mod.rs | 2 -
.../server/scenarios/authentication_scenario.rs | 5 -
.../tests/server/scenarios/encryption_scenario.rs | 10 +-
.../scenarios/restart_offset_skip_scenario.rs | 5 +-
.../stale_client_consumer_group_scenario.rs | 262 +-
core/metadata/src/impls/metadata.rs | 427 ++-
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/stream.rs | 116 +-
core/metadata/src/stm/user.rs | 21 +-
core/partitions/Cargo.toml | 9 +-
core/partitions/src/iggy_index.rs | 6 +-
core/partitions/src/iggy_index_writer.rs | 4 +
core/partitions/src/iggy_partition.rs | 229 +-
core/partitions/src/lib.rs | 14 +
core/{server => partitions}/src/offset_recovery.rs | 22 +-
core/partitions/src/partition_storage.rs | 725 +++++
core/partitions/src/persistence.rs | 49 +-
.../{server => partitions}/src/segment_recovery.rs | 703 +++--
core/partitions/src/types.rs | 48 +
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/http/messages.rs | 34 -
core/sdk/src/poll_routing.rs | 32 +
core/sdk/src/vsr.rs | 71 +-
core/server/config.toml | 19 +-
core/server/src/boot/mod.rs | 94 +-
core/server/src/boot/recovery.rs | 43 +-
core/server/src/boot/threads.rs | 12 +-
core/server/src/consumer_group.rs | 14 +-
core/server/src/consumer_group/lease.rs | 160 ++
core/server/src/consumer_group/liveness.rs | 1034 +++++++
core/server/src/dispatch/authz.rs | 81 +-
core/server/src/dispatch/host.rs | 213 ++
core/server/src/dispatch/mod.rs | 224 +-
core/server/src/dispatch/partition.rs | 12 +-
core/server/src/dispatch/session_ops.rs | 18 +-
core/server/src/dispatch/submit.rs | 242 +-
core/server/src/dispatch/test_support.rs | 9 +-
core/server/src/http/reads.rs | 125 +-
core/server/src/lib.rs | 14 +-
core/server/src/namespace.rs | 218 +-
core/server/src/partition_helpers.rs | 792 +-----
core/server/src/partition_reconciler.rs | 87 +-
core/server/src/responses.rs | 27 +-
core/server/src/server_error.rs | 320 +--
core/server/src/session_manager.rs | 72 +-
core/server/src/shell.rs | 53 +-
core/server_common/src/consensus_message.rs | 16 +-
core/server_common/src/sharding/mod.rs | 10 +
core/shard/src/builder.rs | 26 +-
core/shard/src/host.rs | 103 +
core/shard/src/lib.rs | 208 +-
core/shard/src/poll/completion_tests.rs | 12 +-
core/shard/src/router.rs | 6 +-
core/simulator/README.md | 1 +
core/simulator/src/client.rs | 18 +-
.../simulator/src/consumer_offset_history_tests.rs | 220 ++
core/simulator/src/lib.rs | 277 +-
core/simulator/src/packet.rs | 7 +-
core/simulator/src/replica.rs | 53 +-
core/simulator/src/storage/purge.rs | 17 +-
core/simulator/src/storage/tests.rs | 93 +-
.../Iggy_SDK.Examples.Basic.Consumer.csproj | 8 +-
.../Iggy_SDK.Examples.Basic.Producer.csproj | 10 +-
...ggy_SDK.Examples.GettingStarted.Consumer.csproj | 4 +-
...ggy_SDK.Examples.GettingStarted.Producer.csproj | 4 +-
.../Iggy_SDK.Examples.Shared.csproj | 2 +-
...gy_SDK.Examples.MessageEnvelope.Consumer.csproj | 10 +-
...gy_SDK.Examples.MessageEnvelope.Producer.csproj | 10 +-
...ggy_SDK.Examples.MessageHeaders.Consumer.csproj | 4 +-
...ggy_SDK.Examples.MessageHeaders.Producer.csproj | 4 +-
.../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.Producer.csproj | 4 +-
examples/python/pyproject.toml | 4 +-
examples/python/uv.lock | 68 +-
foreign/cpp/MODULE.bazel | 2 +-
foreign/cpp/MODULE.bazel.lock | 7 +-
foreign/cpp/include/iggy.hpp | 19 -
foreign/cpp/src/client.cpp | 9 -
foreign/cpp/src/client.rs | 25 -
foreign/cpp/src/lib.rs | 7 -
foreign/cpp/tests/e2e/client.cpp | 186 --
foreign/cpp/tests/unit/unit_tests.cpp | 1 -
foreign/csharp/Directory.Packages.props | 16 +-
.../FlushMessagesTests.cs | 40 -
.../Iggy_SDK/Contracts/Auth/GlobalPermissions.cs | 3 -
.../csharp/Iggy_SDK/Contracts/StreamPermissions.cs | 3 -
.../csharp/Iggy_SDK/Contracts/TopicPermissions.cs | 3 -
.../csharp/Iggy_SDK/IggyClient/IIggyPublisher.cs | 17 -
.../Implementations/HttpMessageStream.cs | 10 -
.../IggyClient/Implementations/TcpMessageStream.cs | 10 -
foreign/csharp/Iggy_SDK/Iggy_SDK.csproj | 6 +-
foreign/csharp/Iggy_SDK/Utils/CommandCodes.cs | 1 -
foreign/csharp/Iggy_SDK/Vsr/VsrOperation.cs | 4 +-
foreign/csharp/README.md | 3 +-
foreign/csharp/README.nuget.md | 19 +
foreign/go/client/tcp/tcp_offset_management.go | 9 +
foreign/go/internal/command/system_test.go | 105 +
foreign/go/internal/vsr/protocol_parity_test.go | 7 +-
foreign/go/tests/e2e_test.go | 49 +
foreign/java/gradle/libs.versions.toml | 2 +-
foreign/node/package-lock.json | 9 +-
foreign/node/package.json | 2 +-
foreign/node/src/wire/command-set.ts | 4 +-
foreign/node/src/wire/command.code.ts | 1 -
.../wire/message/flush-unsaved-buffers.command.ts | 53 -
foreign/node/src/wire/message/message.utils.ts | 30 +-
foreign/python/apache_iggy.pyi | 34 +
foreign/python/src/client.rs | 46 +
foreign/python/tests/test_connectivity.py | 183 +-
foreign/python/uv.lock | 64 +-
foreign/swift/.swift-format | 22 +
.../consts.go => foreign/swift/Package.swift | 27 +-
foreign/swift/README.md | 96 +
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 +-
.../Sources/Iggy/Utilities/UInt128Value.swift | 156 ++
foreign/swift/Sources/Iggy/Wire/ByteCodec.swift | 218 ++
foreign/swift/Tests/IggyTests/ByteCodecTests.swift | 120 +
foreign/swift/Tests/IggyTests/ErrorCodeTests.swift | 63 +
foreign/swift/Tests/IggyTests/Fixtures/golden.json | 1004 +++++++
foreign/swift/Tests/IggyTests/HashTests.swift | 62 +
.../Tests/IggyTests/Support/GoldenFixture.swift | 73 +
.../swift/Tools/golden-vectors}/Cargo.toml | 22 +-
foreign/swift/Tools/golden-vectors/src/main.rs | 1435 ++++++++++
gateways/kafka/Cargo.toml | 27 +-
gateways/kafka/README.md | 197 +-
gateways/kafka/docs/ACL_MAPPING.md | 195 ++
gateways/kafka/docs/AUTHENTICATION.md | 260 ++
gateways/kafka/docs/BRIDGE_MAPPING.md | 207 +-
gateways/kafka/docs/CONSUMER_GROUPS.md | 191 ++
gateways/kafka/docs/IDEMPOTENCE.md | 139 +-
gateways/kafka/docs/MANUAL_TESTING.md | 198 +-
gateways/kafka/docs/SCOPE.md | 251 +-
gateways/kafka/docs/TEST_SUITE.md | 41 +-
gateways/kafka/docs/kafka_api_keys_reference.md | 48 +-
gateways/kafka/scripts/ci-wire-fixtures.sh | 2 +-
gateways/kafka/src/auth.rs | 805 ++++++
gateways/kafka/src/bridge/config.rs | 53 +-
gateways/kafka/src/bridge/error.rs | 139 +-
gateways/kafka/src/bridge/iggy_bridge/mod.rs | 105 +-
gateways/kafka/src/bridge/iggy_bridge/offsets.rs | 37 +-
gateways/kafka/src/bridge/iggy_bridge/produce.rs | 183 +-
gateways/kafka/src/bridge/iggy_bridge/topics.rs | 330 ++-
gateways/kafka/src/bridge/mod.rs | 8 +-
gateways/kafka/src/bridge/topic_map.rs | 6 +
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 | 4 +
gateways/kafka/src/main.rs | 198 +-
gateways/kafka/src/protocol/acl.rs | 600 ++++
gateways/kafka/src/protocol/api.rs | 437 ++-
gateways/kafka/src/protocol/bounds_guard.rs | 722 ++++-
.../kafka/src/protocol/handlers/api_versions.rs | 34 +-
.../kafka/src/protocol/handlers/create_topics.rs | 711 ++++-
.../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 | 454 ++-
gateways/kafka/src/protocol/handlers/metadata.rs | 544 +++-
gateways/kafka/src/protocol/handlers/mod.rs | 30 +-
gateways/kafka/src/protocol/handlers/produce.rs | 914 +++++-
gateways/kafka/src/protocol/handlers/sync_group.rs | 89 +
gateways/kafka/src/protocol/mod.rs | 2 +
gateways/kafka/src/protocol/sasl.rs | 573 ++++
gateways/kafka/src/records.rs | 2296 +++++++++++++++
gateways/kafka/src/server.rs | 721 ++++-
gateways/kafka/tests/api_handler_tests.rs | 36 +-
.../kafka/tests/bridge_iggy_integration_tests.rs | 272 +-
gateways/kafka/tests/common/codec.rs | 11 +
gateways/kafka/tests/common/iggy_server.rs | 3 +-
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 | 61 +-
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 | 60 +-
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 | 9 +-
gateways/kafka/tests/sasl_tests.rs | 1709 +++++++++++
gateways/kafka/tests/server_e2e_tests.rs | 30 +-
gateways/kafka/tests/version_firewall_tests.rs | 73 +-
gateways/kafka/tools/kafka-tool/src/main.rs | 67 +-
gateways/kafka/tools/kafka-tool/src/response.rs | 18 +-
licenserc.toml | 7 +
web/package-lock.json | 40 +-
web/package.json | 10 +-
339 files changed, 40222 insertions(+), 5680 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/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
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/integration/tests/cli/message/test_message_flush_command.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/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%)
copy
core/integration/tests/connectors/{runtime/sink_transform_error_config/stdout.toml
=> doris/proto_text_config/doris_sink.toml} (60%)
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}
(60%)
create mode 100644 core/integration/tests/connectors/fixtures/floci.rs
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%)
delete mode 100644 core/integration/tests/server/flush_vsr.rs
rename core/{server => partitions}/src/offset_recovery.rs (92%)
create mode 100644 core/partitions/src/partition_storage.rs
rename core/{server => partitions}/src/segment_recovery.rs (89%)
create mode 100644 core/partitions/tests/consumer_offset_history.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/shard/src/host.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/system_test.go
delete mode 100644
foreign/node/src/wire/message/flush-unsaved-buffers.command.ts
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/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/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/CONSUMER_GROUPS.md
create mode 100644 gateways/kafka/src/auth.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/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/sync_group.rs
create mode 100644 gateways/kafka/src/protocol/sasl.rs
create mode 100644 gateways/kafka/src/records.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
