This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch topic_metrics
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 1de12ddbe Merge branch 'master' into topic_metrics
add 4dec2a985 feat(gateways): Kafka Gateway add DeleteTopics API Key that
deletes the Iggy topic only (#4400)
add 72e46049d docs: welcome PR reviews from contributors (#4494)
add d3e95f506 chore(python): require Python 3.11 across SDK and CI (#4421)
add 8ded54789 fix(sdk): keep an explicit disconnect until the next connect
(#4388)
add 8f83f011d feat(python): expose delete_segments on IggyClient (#4357)
add 7a08127a8 feat(gateways): Kafka Gateway add DescribeGroups and
ListGroups Keys (#4401)
add a6d33ba4f Merge branch 'master' into topic_metrics
No new revisions were added by this update.
Summary of changes:
.config/nextest.toml | 1 +
.../actions/python-maturin/pre-merge/action.yml | 2 +-
.github/workflows/_build_python_wheels.yml | 90 ++-
.github/workflows/_test_examples.yml | 2 +-
.github/workflows/coverage-baseline.yml | 2 +-
CONTRIBUTING.md | 13 +
bdd/python/.python-version | 2 +-
bdd/python/pylock.toml | 111 +--
bdd/python/pyproject.toml | 2 +-
bdd/python/uv.lock | 51 +-
core/common/src/traits/client.rs | 9 +-
core/integration/tests/sdk/client_lifecycle.rs | 28 +-
core/sdk/src/client_wrappers/binary_client.rs | 27 +-
.../src/clients/binary_personal_access_tokens.rs | 4 +-
core/sdk/src/clients/binary_users.rs | 4 +-
core/sdk/src/clients/client.rs | 63 +-
core/sdk/src/quic/quic_client.rs | 101 ++-
core/sdk/src/tcp/tcp_client.rs | 175 ++++-
core/sdk/src/websocket/websocket_client.rs | 72 +-
examples/python/.python-version | 2 +-
examples/python/README.md | 2 +-
examples/python/message-headers/common.py | 4 +-
examples/python/pylock.toml | 66 +-
examples/python/pyproject.toml | 2 +-
examples/python/uv.lock | 2 +-
foreign/cpp/include/iggy.hpp | 6 +-
foreign/python/.python-version | 2 +-
foreign/python/Dockerfile.test | 2 +-
foreign/python/README.md | 2 +-
foreign/python/apache_iggy.pyi | 48 +-
foreign/python/pylock.toml | 136 +---
foreign/python/pyproject.toml | 3 +-
foreign/python/src/bin/stub_gen.rs | 3 +-
foreign/python/src/client.rs | 59 +-
foreign/python/tests/test_connectivity.py | 13 +-
foreign/python/tests/test_segment.py | 325 ++++++++
foreign/python/uv.lock | 73 +-
gateways/kafka/README.md | 30 +-
gateways/kafka/docs/BRIDGE_MAPPING.md | 21 +
gateways/kafka/docs/CONSUMER_GROUPS.md | 45 +-
gateways/kafka/docs/MANUAL_TESTING.md | 19 +-
gateways/kafka/docs/SCOPE.md | 60 +-
gateways/kafka/docs/TEST_SUITE.md | 2 +-
gateways/kafka/docs/kafka_api_keys_reference.md | 15 +-
gateways/kafka/scripts/ci-wire-fixtures.sh | 2 +-
gateways/kafka/src/bridge/iggy_bridge/topics.rs | 25 +
gateways/kafka/src/group/mod.rs | 85 +-
gateways/kafka/src/group/state.rs | 853 ++++++++++++++++++++-
gateways/kafka/src/protocol/api.rs | 23 +-
gateways/kafka/src/protocol/bounds_guard.rs | 198 ++++-
gateways/kafka/src/protocol/dedup.rs | 73 ++
.../kafka/src/protocol/handlers/create_topics.rs | 125 +--
.../kafka/src/protocol/handlers/delete_topics.rs | 404 ++++++++++
.../kafka/src/protocol/handlers/describe_groups.rs | 165 ++++
.../kafka/src/protocol/handlers/list_groups.rs | 246 ++++++
gateways/kafka/src/protocol/handlers/metadata.rs | 16 +-
gateways/kafka/src/protocol/handlers/mod.rs | 50 +-
gateways/kafka/src/protocol/mod.rs | 2 +
gateways/kafka/src/protocol/wire_len.rs | 83 ++
gateways/kafka/tests/api_handler_tests.rs | 58 +-
gateways/kafka/tests/common/scope.rs | 3 +
gateways/kafka/tests/common/wire.rs | 91 ++-
gateways/kafka/tests/consumer_group_tests.rs | 675 +++++++++++++++-
.../kafka/tests/delete_topics_real_bridge_tests.rs | 336 ++++++++
gateways/kafka/tests/golden_wire_fixtures_tests.rs | 18 +-
gateways/kafka/tests/kafka_client_e2e_tests.rs | 71 ++
gateways/kafka/tests/sasl_tests.rs | 6 +-
gateways/kafka/tests/server_e2e_tests.rs | 4 +-
gateways/kafka/tests/version_firewall_tests.rs | 38 +-
scripts/ci/sync-python-interpreter-version.sh | 47 +-
scripts/ci/wheel-interpreters.sh | 60 ++
71 files changed, 4800 insertions(+), 658 deletions(-)
create mode 100644 foreign/python/tests/test_segment.py
create mode 100644 gateways/kafka/src/protocol/dedup.rs
create mode 100644 gateways/kafka/src/protocol/handlers/delete_topics.rs
create mode 100644 gateways/kafka/src/protocol/handlers/describe_groups.rs
create mode 100644 gateways/kafka/src/protocol/handlers/list_groups.rs
create mode 100644 gateways/kafka/src/protocol/wire_len.rs
create mode 100644 gateways/kafka/tests/delete_topics_real_bridge_tests.rs
create mode 100755 scripts/ci/wheel-interpreters.sh
