This is an automated email from the ASF dual-hosted git repository. spetz pushed a commit to branch dependabot/npm_and_yarn/web/web-329c181da4 in repository https://gitbox.apache.org/repos/asf/iggy.git
commit fd1fe675bae8a41635fad00dfeaefceeea429a40 Merge: 0b3eb68f8 54d8a49dd Author: Piotr Gankiewicz <[email protected]> AuthorDate: Tue Aug 4 06:38:57 2026 +0200 Merge branch 'master' into dependabot/npm_and_yarn/web/web-329c181da4 Cargo.lock | 90 ++ Cargo.toml | 6 + core/connectors/README.md | 1 + core/connectors/sinks/README.md | 1 + .../connectors/sinks/meilisearch_sink}/Cargo.toml | 44 +- core/connectors/sinks/meilisearch_sink/README.md | 105 ++ core/connectors/sinks/meilisearch_sink/config.toml | 43 + core/connectors/sinks/meilisearch_sink/src/lib.rs | 1412 ++++++++++++++++++ core/integration/tests/cluster/mod.rs | 1 + .../cluster/multi_shard_partition_convergence.rs | 223 +++ .../connectors/fixtures/meilisearch/container.rs | 180 +++ .../fixtures/meilisearch}/mod.rs | 8 +- .../tests/connectors/fixtures/meilisearch/sink.rs | 90 ++ core/integration/tests/connectors/fixtures/mod.rs | 2 + .../connectors/meilisearch/meilisearch_sink.rs | 81 ++ .../{cluster => connectors/meilisearch}/mod.rs | 4 +- .../tests/connectors/meilisearch/sink.toml | 20 + core/integration/tests/connectors/mod.rs | 1 + core/metadata/src/stm/stream.rs | 16 +- core/sdk/src/prelude.rs | 6 +- core/server-ng/Cargo.toml | 7 + core/server-ng/src/dispatch.rs | 68 +- core/server-ng/src/partition_reconciler.rs | 1531 +++++++++++++++++++- core/shard/src/lib.rs | 835 ++++++++++- core/shard/src/metrics.rs | 139 +- core/shard/src/router.rs | 40 +- core/simulator/src/lib.rs | 17 + examples/python/README.md | 23 + examples/python/basic/producer.py | 50 +- examples/python/getting-started/producer.py | 50 +- examples/python/message-headers/common.py | 240 +++ .../message-headers/plain-headers/consumer.py | 77 + .../message-headers/plain-headers/producer.py | 59 + .../message-headers/typed-headers/consumer.py | 77 + .../message-headers/typed-headers/producer.py | 64 + examples/python/pyproject.toml | 5 + foreign/python/Cargo.toml | 1 + foreign/python/Dockerfile.test | 2 +- foreign/python/apache_iggy.pyi | 397 ++++- foreign/python/docker-compose.test.yml | 11 +- foreign/python/src/lib.rs | 5 + foreign/python/src/receive_message.rs | 26 + foreign/python/src/send_message.rs | 41 +- foreign/python/src/user_headers.rs | 791 ++++++++++ foreign/python/tests/test_consumer_group.py | 98 ++ foreign/python/tests/test_message_operations.py | 402 ++++- 46 files changed, 7091 insertions(+), 299 deletions(-)
