This is an automated email from the ASF dual-hosted git repository. krishvishal pushed a commit to branch kafka-fetch in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 753512168ad8b09300642c5148422089caf64dc4 Merge: db9752b79 3a00b5ba1 Author: Krishna Vishal <[email protected]> AuthorDate: Wed Sep 30 09:40:46 2026 +0530 Merge branch 'master' into kafka-fetch .github/workflows/codecov-notify.yml | 54 + .github/workflows/pre-merge.yml | 2 + codecov.yml | 5 + core/common/src/traits/consumer_offset_client.rs | 4 + core/common/src/traits/segment_client.rs | 7 +- 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/impls.rs | 20 + .../tests/cluster/client_table_restart.rs | 20 +- .../tests/connectors/delta/delta_sink.rs | 118 +- .../delta/malformed_table_uri_config/config.toml | 38 + .../connectors/delta/malformed_table_uri_sink.toml | 20 + .../delta/missing_secret_key_config/config.toml | 41 + .../connectors/delta/missing_secret_key_sink.toml | 20 + .../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/http/http_source.rs | 42 + core/partitions/src/iggy_partition.rs | 120 +- core/partitions/tests/consumer_offset_history.rs | 529 ++++ core/sdk/src/poll_routing.rs | 32 + .../simulator/src/consumer_offset_history_tests.rs | 220 ++ core/simulator/src/lib.rs | 3 + foreign/cpp/include/iggy.hpp | 1683 ++++++++++++- foreign/cpp/src/client.cpp | 77 + foreign/cpp/src/client.rs | 6 +- foreign/cpp/src/lib.rs | 3 + foreign/cpp/src/type_conversion.rs | 2 + foreign/cpp/src/type_conversions.cpp | 173 ++ foreign/cpp/tests/e2e/client.cpp | 2658 +++++++++----------- 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/Iggy_SDK/IggyClient/IIggySegment.cs | 6 +- foreign/go/internal/command/session_test.go | 33 + foreign/go/internal/command/user_test.go | 75 + foreign/python/apache_iggy.pyi | 34 + foreign/python/src/client.rs | 46 + foreign/python/tests/test_connectivity.py | 183 +- foreign/swift/README.md | 8 +- 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 ++++ foreign/swift/Sources/Iggy/Wire/ByteCodec.swift | 7 + foreign/swift/Tests/IggyTests/Fixtures/golden.json | 2 + 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 | 7 +- gateways/kafka/docs/OFFSET_STORAGE.md | 49 +- gateways/kafka/docs/SCOPE.md | 27 +- gateways/kafka/docs/kafka_api_keys_reference.md | 9 +- gateways/kafka/tools/kafka-tool/README.md | 10 +- 66 files changed, 7978 insertions(+), 1746 deletions(-)
