This is an automated email from the ASF dual-hosted git repository. hubcio pushed a commit to branch kafka-gateway-perf in repository https://gitbox.apache.org/repos/asf/iggy.git
commit e873f9922472fb954eebc7a7a37abb9e8ab6ac3b Merge: ca96e78ce c03409660 Author: Hubert Gruszecki <[email protected]> AuthorDate: Tue Oct 13 16:21:51 2026 +0200 Merge branch 'master' into kafka-gateway-perf .claude/skills/connector-sdk/SKILL.md | 4 +- .github/workflows/_common.yml | 15 + .github/workflows/_detect.yml | 1 + .github/workflows/post-merge.yml | 1 + .github/workflows/pr-title.yml | 1 + .github/workflows/pr-triage-apply.yml | 278 +++++++++++-- .github/workflows/pre-merge.yml | 1 + .github/workflows/stale-prs.yml | 3 +- AGENTS.md | 6 +- .../src/actors/consumer/benchmark_consumer.rs | 146 ++++++- .../bench/src/actors/consumer/client/high_level.rs | 84 ++-- core/bench/src/actors/consumer/client/interface.rs | 4 + core/bench/src/actors/consumer/client/low_level.rs | 60 +++ .../src/actors/producer/benchmark_producer.rs | 15 +- .../benchmark_producing_consumer.rs | 38 +- core/bench/src/args/common.rs | 6 +- core/bench/src/utils/rate_limiter.rs | 261 +++++++++++- core/cli/src/args/mod.rs | 21 +- core/cli/src/credentials.rs | 13 + core/common/src/traits/client.rs | 11 + core/common/src/utils/topic_size.rs | 32 ++ core/configs/src/configs_impl/file_provider.rs | 7 + core/configs/src/server_config/server.rs | 1 + core/connectors/sdk/src/convert.rs | 128 +++++- core/connectors/sdk/src/encoders/avro.rs | 4 +- core/connectors/sdk/src/lib.rs | 2 +- core/connectors/sinks/delta_sink/src/sink.rs | 42 +- core/connectors/sinks/http_sink/src/lib.rs | 58 +-- core/connectors/sinks/meilisearch_sink/src/lib.rs | 28 +- core/connectors/sinks/s3_sink/src/formatter.rs | 95 +++-- core/connectors/sinks/s3_sink/src/sink.rs | 158 ++++++- core/connectors/sinks/surrealdb_sink/src/lib.rs | 15 +- core/integration/tests/bench.rs | 190 +++++++++ core/integration/tests/cli/common/mod.rs | 11 + .../tests/cli/general/test_help_command.rs | 17 +- .../tests/cli/user/test_login_options.rs | 208 +++++++++- core/integration/tests/server/mod.rs | 2 +- core/integration/tests/server/topic_metrics_vsr.rs | 178 +++++++- core/sdk/src/diagnostic_events.rs | 54 +++ core/sdk/src/http/http_client.rs | 8 +- core/sdk/src/lib.rs | 1 + core/sdk/src/quic/quic_client.rs | 7 +- core/sdk/src/tcp/tcp_client.rs | 35 +- core/sdk/src/websocket/websocket_client.rs | 8 +- core/server/config.toml | 4 +- core/server/src/http/handlers.rs | 107 +++-- core/server/src/http/metrics.rs | 210 +++++++++- core/server/src/segment_cleaner.rs | 41 +- docker-compose.cluster.yml | 191 +++++++++ foreign/swift/README.md | 13 +- .../Sources/Iggy/Models/ResourceOptions.swift | 12 - foreign/swift/Sources/Iggy/Protocol/Batch.swift | 264 ++++++++++++ .../swift/Sources/Iggy/Protocol/CommandCode.swift | 143 +++++++ .../Sources/Iggy/Protocol/ConsensusOperation.swift | 154 +++++++ .../Sources/Iggy/Protocol/ConsensusSession.swift | 89 ++++ .../Sources/Iggy/Protocol/ProtocolVersion.swift | 46 +++ foreign/swift/Sources/Iggy/Protocol/Requests.swift | 348 ++++++++++++++++ .../swift/Sources/Iggy/Protocol/Responses.swift | 459 +++++++++++++++++++++ foreign/swift/Sources/Iggy/Protocol/VSRFrame.swift | 313 ++++++++++++++ foreign/swift/Sources/Iggy/Wire/ByteCodec.swift | 63 ++- foreign/swift/Tests/IggyTests/Fixtures/golden.json | 1 + foreign/swift/Tests/IggyTests/ModelTests.swift | 8 +- foreign/swift/Tests/IggyTests/ProtocolTests.swift | 310 ++++++++++++++ .../Tests/IggyTests/ResponseVectorTests.swift | 322 +++++++++++++++ .../Tests/IggyTests/Support/GoldenFixture.swift | 4 + .../swift/Tests/IggyTests/WireVectorTests.swift | 290 +++++++++++++ foreign/swift/Tools/golden-vectors/src/main.rs | 11 + 67 files changed, 5307 insertions(+), 354 deletions(-)
