This is an automated email from the ASF dual-hosted git repository.
numinnex pushed a change to branch iceberg_connector_atleast_once
in repository https://gitbox.apache.org/repos/asf/iggy.git
from 9a67effd7 feat(connectors): deliver Iceberg sink messages at least once
add c59961ce4 feat(python): add multi-tenant producer and consumer
examples (#4751)
add dfcca2853 Merge branch 'master' into iceberg_connector_atleast_once
No new revisions were added by this update.
Summary of changes:
examples/python/README.md | 22 ++++-
examples/python/multi-tenant/consumer.py | 138 +++++++++++++++++++++++++++++++
examples/python/multi-tenant/producer.py | 121 +++++++++++++++++++++++++++
examples/python/multi-tenant/tenants.py | 123 +++++++++++++++++++++++++++
examples/python/pyproject.toml | 1 +
5 files changed, 404 insertions(+), 1 deletion(-)
create mode 100644 examples/python/multi-tenant/consumer.py
create mode 100644 examples/python/multi-tenant/producer.py
create mode 100644 examples/python/multi-tenant/tenants.py
