This is an automated email from the ASF dual-hosted git repository.
krishvishal pushed a change to branch kafka-fetch
in repository https://gitbox.apache.org/repos/asf/iggy.git
from db9752b79 fix: address review comments round 2
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)
new 753512168 Merge branch 'master' into kafka-fetch
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.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 | 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/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, 7879 insertions(+), 1761 deletions(-)
create mode 100644 .github/workflows/codecov-notify.yml
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%)
create mode 100644 core/partitions/tests/consumer_offset_history.rs
create mode 100644 core/simulator/src/consumer_offset_history_tests.rs
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
