This is an automated email from the ASF dual-hosted git repository. spetz pushed a commit to branch part-mat-barrier in repository https://gitbox.apache.org/repos/asf/iggy.git
commit 1296255fce9a81a98716389eff9a52ef4bf8abfc Merge: 98f4ba2ba 3ca8695d3 Author: Piotr Gankiewicz <[email protected]> AuthorDate: Tue Aug 4 06:11:23 2026 +0200 Merge branch 'master' into part-mat-barrier 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 ++++++++++++++++++++ .../connectors/fixtures/meilisearch/container.rs | 180 +++ .../tests/connectors/fixtures/meilisearch/mod.rs | 22 + .../tests/connectors/fixtures/meilisearch/sink.rs | 90 ++ core/integration/tests/connectors/fixtures/mod.rs | 2 + .../connectors/meilisearch/meilisearch_sink.rs | 81 ++ .../tests/connectors/meilisearch/mod.rs | 18 + .../tests/connectors/meilisearch/sink.toml | 20 + core/integration/tests/connectors/mod.rs | 1 + core/sdk/src/prelude.rs | 6 +- 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 +++++- 36 files changed, 4439 insertions(+), 102 deletions(-)
